spring-rabbitmq

2열

1답변

특정 지속 기간 후 MessageListener에 메시지를 보내야한다는 요구가 있습니다. 따라서 Spring AMQP를 사용하여 달성 할 수있는 방법이 있습니다. 예 : 메시지가 리스너가 바로 그 질문을 듣고 접수됩니다, 프로듀서는 메시지를 생성하고 메시지가 RabbitMQ Q 간다, 나는 몇 가지 구성 매개 변수가 1000MS

0열

1답변

Rabbitmq : 여러 대기열에서 메시지 소비 우선 순위

메시지를 소비 할 대기열이 두 개 있고 하나의 SimpleMessageQueueListenerContainer를 사용하면 두 대기열에 메시지가있을 때 청취자/호출 메시지가 어느 순서로 사용됩니까? 내가 작업하고있는 문제의 구체적하려고합니다 : 나는이 메시지를 큐에서 소비 할 필요가있는 소비자 응용 프로그램이 - 말 정규 작업 대기열 및 드물게 - 작업 -

0열

1답변

Spring RabbitMQ 프로젝트에서 여러 가상 호스트를 사용하는 방법은 무엇입니까?

I했습니다 다음과 같은 두 가지 구성 클래스 : @Configuration @EnableRabbit @Import({ LocalRabbitConfigA.class, CloudRabbitConfigA.class }) public class RabbitConfigA { @Autowired @Qualifier("rabbitConnectio

0열

1답변

토끼 대기열에서 준비되지 않은 큐로 이동하는 토끼 mQ 메시지

게시자와 게시자가 시작됩니다. 이제는 소비자가 시작하고 문제는 메시지가 준비된 대기열에서 메시지가 다시 전달 된 채로 대기열로 이동한다는 것입니다 나는 내가 ACK가 아닌 소비자 재시작에 보낼 경우에만 재 전달 또는 시작으로 표시해야합니다입니다 원하는 avoid.So 할 구성 : @Bean public org.springframework.amqp.rabb

0열

2답변

Spring rabbit : AspectJ 사용없이 @RabbitListener로 주석 된 인터셉트 메소드 호출

AspectJ를 사용하지 않고 @RabbitListener로 주석 된 bean 메소드 호출을 인터셉트 할 수있는 방법이 있는가? 코드는 내가 방법은 @OtherAnnotation 주석이있는 경우, @RabbitListener 방법에 대한 모든 호출을 차단하기 위해 필요한이 @OtherAnnotation @RabbitListener public void

1열

1답변

RabbitMQ Spring에서 메시지를 수동으로 가져 오는 방법

레코드를 RabbitMQ 큐에서 수동으로 가져오고 자동으로 가져 오지 않아도됩니다. 아래는 내가 그렇게 창조 한 것입니다. 그러나, 더 나은 Spring/RabbitMQ 방법이 있는지 궁금합니다. channel.basicAck 및 channel.basicNack을 사용하게됩니다. 나는 소비자가 예외를 던지면 그 레코드가 대기 상태를 유지할 수 있도록 승인

0열

1답변

스프링 AMQP 재시도 메커니즘 : 현재 실행이 원래 실행인지 재 시도인지 알 수있는 방법

래빗 수신기에서 재시도를 적용하는 데 사용되는 메커니즘과 관계없이 구현에서 현재 실행이 원래 실행인지 알 수 있습니까? 예외 후 재심 로그인하고 싶습니다. 또한 그에 따라 조치를 취할 것입니다.

1열

2답변

MessageConversionException : 메시지 내용을 변환하지 못했습니다.

저는 Spring AMQP를 사용하는 SpringBoot Application을 가지고 있습니다. 지금은 공식적인 Spring 문서 예제에서 지시 한대로 JavaConfig 클래스를 사용하여 수신 측을 구현하고 있습니다. 그러나 MessageConversionException을 받고 있는데 메시지가 내 ClientHandler 클래스에 도달하여 메시지를 처

0열

1답변

어디에 멀티 스레드 환경에서 수신 rabbitListener 구성 요소 내에 스레드 종속 데이터를 저장해야합니까?

다중 스레드 환경에서 스프링 amqp의 주석 기반 접근 방식을 사용하고 있습니다 (여러 소비자 => 여러 개의 토끼 수신기 컨테이너가 있음). @RabbitListener(queues = "tasks") public void receiveMessage(@Payload Task task) { // usage of httpClient here wit

0열

1답변

지정된 속도로 rabbitmq에서 메시지 처리

우리는 특정 속도 1ms/2 초로 청취자가 rabbitmq에서 메시지를 읽으려고했습니다. 우리는 지금까지 토끼 mq로 그러한 유틸리티를 찾지 못했습니다. 그래서 DB와 함께 이것을 수행하는 생각, 즉 리스너는 메시지를 읽고이를 DB에 저장하고 나중에 스케줄러가 DB로부터 원하는 비율로 처리합니다. 이 작업을 수행하는 더 좋은 방법이 있다면 제안하십시오. 우