spring-integration-amqp

0열

1답변

spring messaging xml config에 해당하는 Java Config

rabbitMQ를 사용하여 스프링 배치 원격 청크를 구현하려고합니다. 나는 다음과 같은 INBOUND이 <int:channel id="requests"/> <int:channel id="replies"/> <int-jms:message-driven-channel-adapter id="jmsIn" destination-name="requests

java spring spring-batch spring-integration-amqp 2017-11-15

---

1열

1답변

봄 통합 : aggration에 관련된 모든 헤더를 얻을뿐 아니라 I는 다음과 같이 정의 된 Spring 통합의 흐름이 마지막

: IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, "queueName") .id("id") .acknowledgeMode(MANUAL) .autoStartup(autoStartup) .concurrentConsumers(2)

java spring spring-integration spring-integration-amqp 2017-11-27

---

0열

1답변

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

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

spring-integration spring-amqp spring-integration-amqp 2017-10-10

---

0열

1답변

Spring 통합을 사용하여 msg를 json 형식으로 대기열에 넣는 방법 AMQP

현재 json 형식으로 대기열에 메시지를 넣으려고합니다. 아래 코드는 내 코드 조각이지만 작동하지 않습니다. return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, NOTE_INCOMING_QUEUE) .concurrentConsumers(2)) .transfor

spring-integration spring-integration-amqp spring-integration-dsl 2017-05-19

---

1열

1답변

RabbitMQ + Spring 통합. 큐 크기 1 만 삭제하면 내가 지금 가망 경우 RabbitMQ와 Spring 통합이 아이디어를 구현하고자하는

재정의 : 한 큐, 1 메시지 capatity와. 소비자가이 메시지를 요청할 것입니다. 대기열에 있으면 메시지가 전달되고 그렇지 않으면 null 또는 오류가 발생합니다. 이 메시지 (대기열에있는 경우)는 다운로드 된 것으로 삭제되지 않으며 생산자가 다른 새 메시지를 대기열에 넣었을 때만 삭제됩니다. 감사합니다. 이 같은

java rabbitmq spring-integration amqp spring-integration-amqp 2017-12-14

---