내가하고 싶은 것은 HTTP 요청이 봄-webmvc 같은 이, @RequestParam 등을 @RequestMapping 주석을 사용하여 처리하는 매우 유사한 방법으로 처리 AMQP 메시지이다 그러나 대신 HTTP 요청을 내 원본 개체를 AMQP 메시지가됩니다. AMQP 메시지 요청에는 두 개의 헤더가 있습니다 (예 : method="POST"
url="
rabbitMQ 메시지에 고정 응답 큐를 구성하는 데 문제가 있습니다. 다음과 같이 나는 생산자와 소비자가 : public class Producer {
private static ApplicationContext context;
private static RabbitTemplate template;
public static
RabbitMQ를 통해 약 1Mb 크기의 파일을 보내는 것이 좋은가요? 파일에 해당하는 이진 필드가있는 json 형식의 메시지를 보내려고합니다. 스프링 - amqp를 사용하여 올바르게 수행하는 방법은 무엇입니까? 다음 클래스와 함께 객체를 게시하면됩니까? class Message {
String field1;
byte[] fileField
현재이 응용 프로그램에는 3 개의 가상 호스트를 사용해야합니다. 나는 하나의 메시지를 소비자로 만받으며 나머지는 RPC 호출을 위해서만 메시지를 받는다. 현재 각각의 가상 호스트에 하나씩 하위 클래스를 가지고있는 CachingConnectionFactory을 사용하고 있습니다. 그런 다음 각 서브 클래스 콩을 만들고 있습니다. 물론 정확한 가상 호스트 인스
제작을 위해 RabbitMQ와 함께 Spring-AMQP 라이브러리를 사용하고 있습니다. "깔끔하게"작동 할 몇 가지 테스트를 작성하고 싶었고 임베디드 중개인을 사용하고 응답을 조롱하는 것에 대해 생각했습니다. 나는 Rabbit을 임베드 할 수 없다는 것을 알고 있지만 Spring AMQP가 Apollo 또는 JVM에서 작동 할 다른 브로커와 함께 작동하는
여기에 나열된 RabbitMQ "extension"이 http://www.rabbitmq.com/direct-reply-to.html 인 것을 발견했습니다. amq.rabbitmq.reply-to과 함께 RabbitTemplate의 "replyQueue"를 설정했습니다. 이미 RPC 호출로 함수를 시도했지만 작동했지만 지금은 시간이 끝난다. 도움을 주시면
스프링의 xml 구성에 다음과 같은 구성이 있습니다. 내가 동시성을 감소하려면 <rabbit:listener-container id="testListenerContainer" connection-factory="connectionFactory" prefetch="1" concurrency="10">
<rabbit:listener ref="test
Exchange를 통해 메시지를 보내는 여러 호스트가 있습니다. 이러한 여러 호스트에 대해 큐 및 호스트에 바인딩하는 SimpleMessageListenerContainer의 인스턴스를 만들었습니다. 컨테이너에 대한 리스너를 등록했습니다. 메시지 검색에서 나는 특정 종류의 메시지를 찾습니다. 내가 메시지를 받으면 컨테이너를 중지하고 싶습니다만, 컨테이너 인
저는 낙타에 익숙합니다. 한 요소에서 다른 요소로의 입력을 파이프 라인 처리하는 것이 다소 간단합니다. 모든 응용 프로그램 이벤트를 AMQP 대기열, 소방 호스로 보낸 다음 이벤트 유형에 따라 다른 대기열로 이벤트를 라우팅하려고합니다. 예를 들어, 이벤트 유형이 session.created 인 경우 소화 호스에서 꺼내 session.created 대기열로
우리는 프로젝트가 다른 컴퓨터에서 호스팅되는 대기열을 경청해야합니다. 예를 들어 4 개의 가상 호스트가 있습니다. 각 호스트에 대해 SimpleMessageListenerContainer의 새 인스턴스를 만들었지 만 MessageListener의 한 인스턴스 (ChannelAwareListener를 구현하므로 수동으로 응답 할 수 있음)를 사용합니다. Me