Wie erstelle ich Spring Integration Flow aus zwei MessageProducerSpec?
Ich verwende Spring Integration, Java DSL (Version 1.1.3). Ich habe meinorg.springframework.integration.dsl.IntegrationFlow
wie folgt definiert
return IntegrationFlows.from(messageProducerSpec)
.handle(handler)
.handle(aggregator)
.handle(endpoint)
.get();
}
messageProducerSpec
ist eine Instanz vonorg.springframework.integration.dsl.amqp.AmqpBaseInboundChannelAdapterSpec
Ich möchte, dass mein Integrationsablauf Nachrichten von ZWEI separaten @ konsumiermessageProducerSpecs
(zwei separateSimpleMessageListenerContainers
, jeweils mit diffrentConnectionFactory
). Wie ist es möglich, integrationFlow aus mehr als einer messageProducerSpec zu erstellen? Es wird keine Integrationskomponente angezeigt, die Nachrichten aus mehreren Quellen verarbeiten kann.