-
Notifications
You must be signed in to change notification settings - Fork 33
Jms inbound gateway
NOTE: Version 1.0.0.M1 of Sprint Integration Scala DSL provides initial and very basic support for JMS Inbound Gateway which will be enhanced in subsequence milestones. Please follow https://jira.springsource.org/browse/INTSCALA-25 for status of these enhancements
Continuation from JMS Inbound Gateway could be expressed using '-->' operator.
Root DSL element for JMS Inbound Gateway is jms
jms.listen(requestDestinationName = "myQueue", connectionFactory = connectionFactory) -->
As you can see from the above sample all that is needed to create a JMS Inbound Gateway is to invoke listen method providing Destination name and reference to a ConnectionFactory.
For simple testing with embedded ActiveMq broker we provide a utility class in the test package to create a ConnectionFactory
val connectionFactory = JmsDslTestUtils.localConnectionFactory
[Back to Inbound Adapters and Gateways] (https://github.com/SpringSource/spring-integration-scala/wiki/Inbound-adapters-and-gateways)