spring-rabbitmq

0열

1답변

이전 메시지 처리가 진행 중일 때 spring-amqp onMessage() 메소드가 다음 메시지를 처리하지 않음

MessageListener를 사용하여 지정된 큐에서 메시지를 읽었으며 큐에 메시지가 도착하면 처리를 수행하려고합니다. 여기 @Bean public MessageListenerContainer messageListenerContainer() { SimpleMessageListenerContainer messageListenerContainer

2열

1답변

Spring rabbitmq 테스트 - RabbitListenerTestHarness가 리스너를 찾지 못했습니다.

spring rabbitmq 어플리케이션에 대한 몇 가지 테스트를 작성하려고합니다. documentation에서 RabbitListenerTestHarness를 사용하여 예제를 발견했습니다. 소스에서 @RunWith(SpringJUnit4ClassRunner.class) @SpringApplicationConfiguration(classes = MyMai

3열

4답변

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

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

2열

1답변

RabbitMQ Java 클라이언트가 메시지 사용을 중지합니다.

내 응용 프로그램은 RabbitMQ에서 일부 메시지를 소비하고 처리합니다. 약 10 개의 대기열이 있으며 각 대기열에는 최대 10 명의 소비자 (스레드)가 있습니다. 프리 페치가 5입니다. CloudAMQP 플러그인 (RabbitMQ 서비스)을 사용하여 Heroku에서 설정을 실행하고 있습니다. 기본 하트 비트 및 연결 시간 제한 설정 (60 초)으로 실행

3열

1답변

스프링 토끼의 심장 박동수를 늘리십시오

설치가 완료되면 problems이 보입니다. 가능한 수정을 테스트하기 위해 하트 비트 간격을 늘리려고합니다. 나는 Spring boot 1.3.2.RELEASE Spring rabbit 1.5.3.RELEASE 을 사용하고 그리고 연결 팩토리를 인스턴스화하는 코드는 문제는 하트 비트 간격이 변경되지 않는 것입니다 아래 RabbitConnectionFa

0열

1답변

RabbitMQ 용 spring을 사용하여 여러 개의 rabbitTemplate을 사용할 때 Exchange가 자동으로 생성되지 않음

CachingConnectionFactory를 사용하여 Bean을 만들어 대기열과 Exchange가 존재하지 않는 경우 자동으로 생성되도록했습니다. 다른 bean RabbitTemplate을 만들고 내부에 교환을 설정했습니다. @Bean public RabbitTemplate receiptRabbitTemplate() throws URISyntaxExce

1열

1답변

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

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

1열

1답변

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

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

0열

3답변

스프링 - 부트 비활성화로드 - 온 시작 rabbitMQ

스프링 부트 jar를 빌드하는 동안 RabbitMQ가 트리거되거나 실행되는 이유 Application.java 또는 pom.xml을 실행하는 중 RabbitMQ가 트리거되거나 실행되는 이유는 무엇입니까? 나는 다음과 같은 로거 2016-07-01 16:40:04.334 INFO 7004 --- [ main] com.rabbit.App : N

0열

1답변

recieveAndConvert()에서 null 응답을 받음 spring -amqp

replyQ에서 작성하여 하나의 직접 교환으로 비딩했습니다. replyto 속성을 "replyQ"로 설정하여 메시지를 생성했습니다. 그리고 다른 서비스에 대한 메시지를 토끼에게 보냅니다. 다른 끝에있는 서비스가 메시지를 받고 지정된 replyTo 큐에서 응답을 보냅니다. 지금은 template.receiveAndConvert(replyQueue)); 를