spring-amqp

2열

2답변

Spring Boot를 사용하여 RabbitMQ dead-lettered 메시지의 x-death 헤더를 읽는 방법은 무엇입니까?

나는이 answer에서 설명한대로 데드 레터 (dead-lettered) 메시지의 재 라우팅을 구현하려고합니다. 나는 봄 설정을 사용하고있다. 원본 라우팅 키와 원본 큐를 가져 오기 위해 머리글을 읽는 방법에 대해서는 잘 모릅니다. @Configuration public class NotifEngineRabbitMQConfig { @Bean

2열

1답변

스프링 통합 amqp 아웃 바운드 어댑터 경쟁 조건?

프로덕션 애플리케이션 중 하나에서 다소 복잡한 스프링 통합 -amqp 사용 사례가 발생했으며 시작시 "org.springframework.integration.MessageDispatchingException : Dispatcher에 구독자가 없습니다"예외가 발생했습니다. 시작시 초기 오류가 발생하면 동일한 구성 요소에서 예외가 더 이상 표시되지 않습니다.

0열

1답변

RabbitMq logback appender 구성에 문제가 있습니다

내 프로젝트는 중앙 위치 (Graylog) 서버에서 로그를 보내도록 요구합니다. 그래서 나는 RABbitMq에 로그를 보내기 위해 logback.xml에서 "AMQP Appender"를 사용하고 RabbitMq에서 로그를 가져 오도록 Graylog 서버를 구성 할 것을 고려했다. 이것은 내 logback.xml의 모습입니다. <?xml version="1.

1열

1답변

봄 부팅 + 봄 통합 (AMQP)

나는 봄의 통합에 대한 문서를 읽고,하지만 난 여전히 다음과 같은 통합 모델링하는 방법을 알아낼 수 없습니다 : 나는 싶은 것이 기본적으로 +----------+ --- (request) --> +----------+ --- (request) --> +----------+ | Service1 | | RabbitMQ | | Service2 |

1열

1답변

SimpleMessageListenerContainer를 사용하여 RabbitMQ 프리 페치 횟수를 비활성화하는 방법

RabbitMQ는 선택적으로 프리 페치 횟수를 설정할 수있는 기능을 제공합니다. spring-amqp의 SimpleMessageListenerContainer을 사용하여 프리 페치 횟수가 항상 설정되어 있음을 발견했습니다. SimpleMessageListenerContainer은 최소한 txSize으로 설정하기 때문에 프리 페치 카운트를 0으로 설정할 수

0열

2답변

AmqpProxyFactoryBean + AmqpInvokerServiceExporter를 사용하여 사용자 정의 헤더 추가

AmqpProxyFactoryBean ("클라이언트") 및 AmqpInvokerServiceExporter ("서버")을 사용하여 통신하는 두 개의 개별 서비스가 있습니다. 이제 AMQP 프록시를 통해 만들어진 모든 요청에 일부 사용자 지정 헤더를 포함시키고 "서버"에서 액세스 할 수있게하려고합니다. 내가 이것을 성취 할 수있는 쉬운 방법이 있습니까?

0열

1답변

스프링 amqp가 교환을 재 선언 할 수 없다. (xml config)

우리는 Rabbitmq 교환이 이전에 Spring xml 설정 파일에서 선언되었던 기존 프로젝트를 가지고있다. 이제 회사 Rabbitmq 설정이 변경되어 교환이 다른 프로젝트에서 선언되고 프로젝트가 이미 선언 된 교환의 대기열에 게시되어야합니다. 2015-02-03 13:10:35,374 ERROR [pool-12-thread-1] [CachingConne

1열

1답변

Rabbitmq 소비자가 반복적으로 종료 됨

지수 백 오프 정책을 사용하여 데드 레터 교환을 구성했습니다. Received shutdown signal for consumer tag=amq.ctag--Qn9jFNOd3vxhaHvEw8Nrw com.rabbitmq.client.ShutdownSignalException: connection error at com.rabbitmq.client.impl

3열

2답변

amqp가있는 rabbitmq - AmqpException의 경우에 메시지가 표시되지 않습니다.

AmqpException을 내 소비자에게 던지고 있습니다. 메시지는 FIFO 순서로 대기열로 다시 돌아오고 나중에 언젠가 재 처리 될 것으로 예상됩니다. 마치 봄 AMQP가 메시지를 대기열로 다시 보내지 않는 것처럼 보입니다. 대신 실패한 메시지를 반복해서 다시 처리하려고합니다. 새로 도착한 메시지가 처리되지 않습니다. 붙어있는 것들은 AMQP 콘솔 내부의

0열

1답변

Spring AMQP는 rabbitmq 연맹을 지원합니까?

스프링은 <rabbit:connection-factory>의 "addresses"속성을 통해 rabbitmq 클러스터링을 지원한다는 것을 알고 있습니다. 그것은 연합 rabbitmqs에 대한 지원을 제공합니까? 그렇다면 어떻게?