Inbound adapters and gateways

JMS Inbound Gateway represents ListeningIntegrationComposition type. This means two things

1. ListeningIntegrationComposition can only be the first element in the message flow.
2. You can not send a Message to a messaging flow that begins with the ListeningIntegrationComposition, therefore send(..)* methods will not be available on such composition. Instead you will have start and stop method.

For example:

val connectionFactory = JmsDslTestUtils.localConnectionFactory

val flow =
      jms.listen(requestDestinationName = "myQueue", connectionFactory = connectionFactory) -->
      handle.using { m: Message[_] => println("logging existing message and passing through " + m); m } -->
      transform.using { value: String => value.toUpperCase() }

    
flow.start

...

flow.stop

[JMS Inbound Gateway] (https://github.com/SpringSource/spring-integration-scala/wiki/JMS-Inbound-Gateway)

Back to Reference