Message Channel

EIP reference for Message Channel can be found here - http://www.eaipatterns.com/MessageChannel.html

We currently support several types of Message Channels

Point-to-Point Channel

EIP reference for Point-to-Point Channel can be found here - http://www.eaipatterns.com/PointToPointChannel.html

val pointToPointChannel = Channel("myDirectChannel")

Publish-Subscribe Channel

EIP reference for Publish-Subscribe Channel can be found here - http://www.eaipatterns.com/PublishSubscribeChannel.html

val publishSubscribeChannel = PubSubChannel("myPubSubChannel")

If you need to add any extra properties to the PubSubChannel you may do so using fluent API available with PubSubChannel. The following is available for PubSubChannel:

PubSubChannel("myPubSubChannel").applyingSequence // will set _sequenceSize_ and _sequenceNumber_ headers

PubSubChannel("myPubSubChannel").withExecutor(Executors.newCachedThreadPool()) // reference to instance of _java.util.concurrent.Executor_

// combination of both
PubSubChannel("myPubSubChannel").applyingSequence.withExecutor(Executors.newCachedThreadPool()) 

[Back to Reference] (https://github.com/SpringSource/spring-integration-scala/wiki/Reference)