The following snippet shows extracts related to setting up the message broker from the Source, Transformer, and Sink applications:
#Source LogCachingConnectionFactory : Created new connection: SimpleConnection@725b3815 [delegate=amqp://guest@127.0.0.1:5672/, localPort= 58373]#Transformer Logo.s.i.endpoint.EventDrivenConsumer : Adding {transformer:stockIntelligenceProcessorApplication.addOurInventory.transformer} as a subscriber to the 'input' channelo.s.integration.channel.DirectChannel : Channel 'application:0.input' has 1 subscriber(s).o.s.i.endpoint.EventDrivenConsumer : started stockIntelligenceProcessorApplication.addOurInventory.transformero.s.i.endpoint.EventDrivenConsumer ...
