spring-amqp

1열

2답변

SpringAMQP에서 메시지 레벨을 지연시키는 방법을 식별하는 데 어려움이 있습니다. 서비스를 사용할 수 없거나 일부 예외가 발생할 경우 WebService를 호출합니다. 모든 요청을 RabbitMQ 큐에 저장하고 성공적으로 실행될 때까지 서비스 호출을 다시 시도합니다. 서비스가 오류를 던지거나 사용할 수없는 경우 rabbitMQ 리스너는 루핑을 계속합니

0열

1답변

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

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

4열

1답변

Spring 응용 프로그램 종료시 RabbitMQ 메시지 보내기

응용 프로그램 시작, 응용 프로그램 종료 및 모든 분 (틱)에 대해 rabbitMQ에 메시지를 보내는 모니터 서비스가 있습니다. 시작 및 틱 이벤트가 정상적으로 작동합니다. 클래스가 원래 작성되었을 때 시스템 종료 이벤트도 작동했습니다. 내가 사용하고 스프링 부팅 스타터 AMQP 이벤트가 DisposableBean 인터페이스의 destroy 방법에 해고되었

2열

1답변

spring-amqp와 spring-cloud-sleuth 통합

나는 단지 spring-cloud-sleuth으로 첫 걸음을 내딛고 있으며, 모든 종류의 http 호출로 잘 작동합니다. 이제 메시징 부분도 다루려고합니다. 나는 spring-cloud-sleuth이 spring-integration과 통합되었음을 알았다. 현재 spring-amqp 만 사용 중입니다. 이 방법을 사용할 수있는 방법이 있습니까? 누구나 통찰

1열

1답변

spring-amqp를 사용하여 Rabbit MQ 브로커와의 연결을 닫는 방법

우리는 언젠가 이것을 위해 고심하고 있습니다. 아래의 구성입니다 : 우리는 자바 코드에서 연결 팩토리에 액세스하고 파괴하는 방법을 실행하려고하면 <?xml version="1.0" encoding="UTF-8" ?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://w

1열

1답변

Spring amqp @RabbitListener 런타임 유형 문제

spring-amqp에서 nice @RabbitHandler 주석을 사용하여 RestControllers의 코딩 스타일과 비슷하지만 후드에서 Rabbit과 작동하는 엔드 포인트를 작성합니다. 그것들은 모두 아주 멋지고 깔끔하며 시그니처를 기반으로하는 메서드 핸들러의 동적 인 분해능과 함께 특히 훌륭하게 작동합니다. 그러나 우리는 여기서 약간의 논란에 직면

0열

1답변

웹 응용 프로그램 시작시 Spring AMQP를 사용하여 새 대기열 만들기

웹 응용 프로그램의 서버 시작시 Spring AMQP를 사용하여 RabbitMQ에 새 대기열을 만들려고합니다. 나는 정확한 컨피규레이션 코드를 얻지 못하고있다. 다음은 제 코드입니다. 다음을 수정하십시오. @Configuration public class RabbitMQConfiguration { @Bean public Connect

0열

1답변

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

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

1열

1답변

스프링 부트 - 다른 이름으로 공통 응용 프로그램 속성 공개

봄이 여러 패키지에 제공하는 다양한 공통 응용 프로그램 속성에 대한 별칭 역할을하는 사용자 지정 응용 프로그램 속성이 필요한 요구 사항이 있습니다. 예 : 응용 프로그램 속성 foo.host에 값을 설정할 때마다 spring.rabbit.host 속성 값을 설정해야합니다. 마찬가지로 foo.port의 값을 설정하면 spring.rabbitmq.port의 값

3열

4답변

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

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