현재 json 형식으로 대기열에 메시지를 넣으려고합니다. 아래 코드는 내 코드 조각이지만 작동하지 않습니다. return IntegrationFlows.from(Amqp.inboundAdapter(connectionFactory, NOTE_INCOMING_QUEUE)
.concurrentConsumers(2))
.transfor
다음과 같은 간단한 Spring IntegrationFlow가있어 org.springframework.integration.MessageDispatchingException: Dispatcher has no subscribers을 제공합니다. 이것은 흐름의 마지막 단계 인 log 단계와 관련이있는 것으로 보입니다. log 단계를 제거하거나 해당 단계 후에