spring-rabbit

0열

1답변

우리는 auto-startup = "true"를 사용하여 모든 것이 잘 작동합니다. 우리는 Controlbus를 사용하여 어댑터를 시작/중지했습니다. 자동 시작 = "false"를 변경 한 다음 제어 버스를 사용하여 어댑터를 시작해야합니다. 자동 시작 = "거짓"으로 인해 프로세스가 중지됩니다 (작동하지 않음). 어떻게 프로세스를 실행할 수 있지만 인바운드

0열

1답변

이미지를 JSON 메시지로 base64로 인코딩해야합니까? 아니면 Spring AMQP에서 BytesMessage로 반환해야합니까?

스프링 amqp를 통해 POJO를 사용하여 기본 요청/응답 메시징을 설정했으며 JSON 메시지 변환기를 통해 RabbitMQ로 교환합니다. 내 응답 pojo의 페이로드는 지금까지 간단한 문자열 이었지만 지금은 때때로 이미지로 답장을 보내야합니다. 1)이 문제를 해결하는 가장 좋은 방법은 무엇입니까? 이미지가 JSON 메시지의 페이로드 문자열로 인코딩 된 b

0열

1답변

파일 인바운드 어댑터 동일한 파일을 처리하는 여러 스레드

우리는 들어오는 폴더를 모니터링하고 파일을 처리하는 스프링 통합 응용 프로그램을 가지고 있습니다. 나는 prevent-duplicates = "true"를 사용하고 있었지만 false로 변경해야합니다. 나는 이유를 설명했다. file inbound-channel-adapter performance issue 이제 동일한 파일을 처리하는 여러 스레드가 표시됩

1열

1답변

스프링 - amqp- 최신 수신 대기자

죄송합니다. amqp 세계에 새로 왔습니다. public class HelloApp { public static void main(String[] args) { ApplicationContext context = new ClassPathXmlApplicationContext("spring-config.xml"); final TestS

0열

1답변

RabbitMQ 자습서 코드가 작동하지 않습니다.

나는 RabbitMQ를 배우는 중입니다. 나는 그들의 웹 사이트의 기본 rabbitmq 자습서 시작, 불행하게도 나는 인해 다음과 같은 오류로 컴파일 할 수 없습니다입니다 : ConnectionFactory factory = new ConnectionFactory(); factory.setHost("localhost"); 오류 : "형식적인 Conne

1열

1답변

여러 콘텐츠 유형을 처리하는 비동기 메시지 수신자를 Spring AMQP에 둘 수 있습니까?

나는 메시지를 받기 위해 Spring-AMQP에서 비동기 메시지 수신기를 사용하고있다. 현재 JSON 콘텐츠가있는 메시지 만 처리되지만 XML 콘텐츠가있는 메시지도 처리해야합니다. MessageListener의 나의 현재 구현은 MessageConverter 주입이와 같이, onMessage(Message)에서 그것을 사용 MyMessage myMessag

1열

1답변

큐를 복구 한 후 바인딩 재 선언

현재 rabbit-amqp 구현 프로젝트에서 작업 중이며 spring-rabbit을 사용하여 프로그래밍 방식으로 모든 대기열, 바인딩 및 교환을 설정합니다. 나는 그것을 삭제 된 경우 큐를 다시 시도하고 참조 문서에 다음을 발견 해요 : 처리를위한 개선의 숫자를 도입 3.14 리스너 컨테이너 대기열 버전 1.3 리스너 컨테이너의 여러 대기열 컨테이너는 하나

0열

1답변

토끼가 소비자가 계속 사용할 수 있는지 자동으로 확인하는 방법과 목록에서 삭제하지 않는 방법은 무엇입니까?

초기 상태 : 는 토끼 한 소비자는 연결 한 이벤트 : 토끼를 다시 연결을 시도 소비자하지만 소비자 목록 의에 토끼 소비자가 : 토끼와 소비자 사이의 네트워크 연결이 결과를 파산 다음 이벤트 : 네트워크 연결이 다시 작동되고 소비자가 Rabbit에 다시 연결되지만 이전 토끼 연결이 사라지지 않습니다. 결과 : 비활성 소비자 질문에 메시지를 보내려고 토끼 :

0열

1답변

여러 소비자의 경우 RabbitMQ ACK/NACK 시간 범위 정의

소비자가 rabbitmq 서버를 승인해야하는 시간을 설정할 수 있습니까 그렇지 않으면 RabbitMQ 서버가 메시지를 승인하지 않은 것으로 간주해야합니다. 다른 소비자에게 주어진거야?

1열

1답변

메시지가 사용 된 RabbitMQ 대기열의 이름 검색

SimpleMessageListenerContainer을 사용하여 여러 대기열에 첨부되고 ChannelAwareMessageListener으로 구성됩니다. 메시지가 소비 된 큐를 결정할 수 있습니까? 특히 메시지가 Exchange에서 대기열로 라우팅 된 경우 MessageProperties#getReceivedRoutingKey에 큐 이름이 포함될 메시지를