spring-rabbit

1열

1답변

RabbitMQ 클러스터에서 MessageListenerContainer를 중지하십시오.

두 개의 개별 시스템에 RabbitMQ 클러스터를 만들고 메시지 생성자가 RabbitMQ로드 밸런서에 메시지를 보냅니다. 메시지 소비자는 또한 RabbitMQ로드 밸런서에 연결합니다. 이제 특정 대기열의 수신기를 잠시 중단 시키십시오. 이 경우 ListenerContainer의 stop() 메서드가 도움이 될 수 있습니다. 하지만 이것이 두 RabbitMQ

1열

1답변

Spring Rabbit에서 RabbitTemplate을 완전히 종료하려면 어떻게해야합니까?

스프링 래빗을 사용하여 RabbitTemplate.convertAndSend을 사용하여 토끼 대기열에 여러 개의 메시지를 넣은 다음 스크립트를 종료했습니다. 그러나 Rabbit 연결은 메시지가 대기열에 추가 된 후에도 앱을 계속 유지합니다. 메시지를 대기열에 넣은 후 Rabbit 서버에 완전히 멈추는 방법을 찾지 못했습니다. 필자가 해낼 수 있었던 가장 좋

0열

1답변

교환기에 rabbitmq 소비자 연결 해제 및 다시 연결

교환기에서 특정 이벤트에 대한 rabbitmq 소비자를 분리해야 대기열의 메시지 소비를 중단하고 동일한 소비자를 다시 메시지를 교환하고 시작하십시오. 나는 Spring-RabbitMQ 1.6을 사용하고있다. 지금까지 인터넷에서 몇 페이지를 읽었습니다. http://www.programcreek.com/java-api-examples/index.php?api

0열

1답변

amqp로 봄 부팅시 주석 기반 수신기를 사용하는 메시지를 NACK하는 올바른 예외 유형은 무엇입니까?

나는 spring-amqp와 annotation 기반 청취자가있는 spring boot를 사용하여 rabbitmq broker로부터 메시지를 소비한다. 나는이 같은 방법을 포함하는 스프링 요소했습니다 : @RabbitListener(queues = "tasks") public void receiveMessage(@Payload Task task)

0열

2답변

대기열에있는 메시지 대기열

대기열에있는 메시지가 있지만 메시지가 성공적으로 전송되면 대기열에서 메시지를 삭제하고 싶지 않습니다. 다른 시간에 다시 트리거하기 위해 메시지를 보관하고 싶습니다. 누구도 rabbitMQ를 구성하는 방법에 대한 아이디어가 있습니까?

0열

1답변

RabbitMQ 용 Spring SimpleMessageListenerContainer가 유효하지 않은 메시지에서 중단 중임

Spring SimpleMessageListenerContainer를 사용하여 RabbitMQ 대기열에서 메시지를 소비합니다. 모든 것이 정상적으로 작동하지만 잘못된 메시지가 대기열로 전송되면 (예 : 유효하지 않은 json) 수신 대기자가 중단되고 작업자가 종료되며 더 이상 메시지를받지 않습니다. 깨진 메시지를 삭제하고 추가 메시지를 계속 수신하는 방식으

0열

1답변

토끼 : 데드 레터 Q로 라우팅 할 때 메시지 전달 모드를 PERSISTENT로 설정

토끼 수신자가 거부 한 후 메시지를 수신 대기열로 보내려면 PERSISTENT로 설정해야합니다 (원래 수신자가 거부 한 후에 만). 데드 레터 큐 전체를 PERSISTENT (메시지 배달 모드와 관계없이)로 만들 수있는 방법이 있다면 저에게도 도움이됩니다. 사전

0열

1답변

봄 AMQP 우선 순위 메시지

RabbitMQ의 대기열에있는 메시지 우선 순위. 그것은 rabbitmq java 클라이언트와 함께 일하고 있습니다. 그러나 스프링 - 토끼 의존성에서는 작동하지 않습니다. 한번 봐주세요. RabbitMQ Server 버전 - 3.6.5 얼랑 - OTP 19 (8.0) RabbitMQ 자바 클라이언트에게 의 pom.xml <project xmlns="htt

0열

1답변

SimpleMessageListenerContainer에서 다른 MessagePostProcessors의 순서를 얻는 방법

SimpleMessageListenerContainer.setAfterReceivePostProcessors API를 사용하여 SpringAMQP에 여러 개의 MessagePostProcessors를 설정 했으므로 이제는 내 쿼리에서 언급 한 순서대로 이러한 MessagePostProcessors가 호출됩니다. Pseoudo 코드 SimpleMessageL

3열

4답변

스프링 부트 테스트에서 spring amqp/rabbit를 모방하는 방법

스프링 rabbitmq/amqp를 모의하는 방법 어떻게 자동 교환/대기열을 만들려고 시도하는 동안 스프링 부트 테스트에서 실패하지 않을까요? 내가 대기열 및 교환의 원인이됩니다 간단한 RabbitListener 자동차는 다음과 같이 생성 할 수 있습니다 감안할 때 : @ActiveProfiles("test") @RunWith(SpringRunner.cla