spring-amqp

0열

1답변

Jackson2JsonMessageConverter가있는 AmqpChannelFactoryBean이 유형을 저장하지 않는 이유는 무엇입니까?

RabbitMQ와 함께 Spring 통합 채널을 사용하여 RabbitMQ와 Spring 통합을 사용하려고합니다. (어떤 이유로 든 거의 문서화되지 않은 것처럼 보입니다.이게 새로운 것입니까?). 이렇게하려면 AmqpChannelFactoryBean을 사용하여 채널을 만들 수있는 것 같습니다. 메시지 변환을 설정하기 위해 Jackson2JsonMessageC

0열

1답변

메시지 SpringBootApplication

에 바인딩, 전송하지 나는 다음과 같이 메시지를 보내려고 : rabbitTemplate.convertAndSend("my.exchange", "my.queue", "Test Message"); 을 다음과 같이 메시지가 나타납니다하려고 : @RabbitListener(bindings = @QueueBinding(value = @Queue(value = "

0열

1답변

Spring AMQP 자동 스케일링 그룹

그래서 주제 교환을 사용하여 Spring AMQP와 Spring Cloud Stream에 대한 연구를 해왔다. AWS 자동 확장 그룹에 해당 앱이있는 경우 앱의 추가 인스턴스가 동일한 교환에 가입하고 중복 메시지를 수신합니까?

1열

1답변

Spring RabbitListener 별칭을 만들 수 있습니까?

나는 다른 모듈을 통해 내 코드의 여러 위치에 붙여 넣기 한 청취자가 @RabbitListener(id="example", queues={"a", "b"})입니다. 나는 같은 별칭을 만들고 싶었 : @Target({ ElementType.TYPE, ElementType.METHOD, ElementType.ANNOTATION_TYPE }) @Retentio

1열

1답변

Spring Cloud Stream Ribbit MQ에 자동으로 다시 연결

RabbitMQ 서버에 연결하는 Spring Cloud Stream 애플리케이션이있다. Rabbit MQ에서 rabbitmq-auth-backend-uaa 플러그인을 사용하고 있지만 문제는 아닙니다. 이 플러그인은 Rabbit MQ와의 연결이 생성 될 때 사용자 이름으로 보내지는 oAuth2.0 JWT 토큰을 확인합니다. 이렇게하려면, 내 봄 응용 프로그램

1열

2답변

Spring RabbitTemplate - 보내는 즉시 자동으로 대기열을 만드는 방법

RabbitMQ와 Spring의 RabbitTemplate을 함께 사용하고 있습니다. 템플릿 send 메소드를 사용하여 대기열로 메시지를 보낼 때 대기열이 이미 존재하지 않으면 자동으로 작성/선언됩니다. 우리의 비즈니스 로직에 따르면 큐 이름은 런타임에 생성되므로 미리 선언 할 수 없으므로 매우 중요합니다. 이전에는 JmsTemplate을 사용했으며 보내거

0열

1답변

Spring AMQP 및 CachingConnectionFactory

두 개의 주소가있는 CachingConnectionFactory가있는 경우 언제 어떤 서버에 연결되어 있는지 알 수 있습니까? 그리고 수동으로 하나에서 다른 것으로 변경하는 가장 좋은 방법은 무엇입니까? CachingConnectionFactory cf = new CachingConnectionFactory(factory); String _addresse

1열

1답변

봄 amqp의 비 일괄 처리 메시지

BatchingRabbitTemplate을 사용하여 일괄 처리로 메시지를 amqp 끝점으로 보내고 있습니다. 이제 다른 수신 측에서는 @RabbitListener을 사용하여 메시지를받을 수 있지만 내 문제는 메시지가 자동으로 일괄 처리되어 @RabbitHandler public void receive (List<SomeObject> so)을 사용할 수 없다

0열

1답변

spring integration rabbitmq 준비 상태 메시지

나는 spring과 rabbitmq의 통합 상황이 있습니다. 메시지는 대기열로 보내지지만 준비 상태로 끝나고 승인되지 않은 메시지로 보내지지만 소비자는 메시지를 가져 오지 않습니다. 들으 XML 구성은 다음과 같이이다 : 서버에서 <beans xmlns="http://www.springframework.org/schema/beans" xmlns:x

0열

2답변

Spring-Boot/AMQP - 처리 할 메시지 수 제한

스프링 부트 AMQP 라이브러리를 사용하는 스프링 부팅 응용 프로그램이 있습니다. 의 pom.xml : <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency> 가 어떻게 그것