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

Continuation from all types of channels could be expressed using '-->' (to single subscriber) or '--<' (to multiple subscribers) see an example [here] (https://github.com/olegz/scala-dsl-sample/blob/master/src/test/scala/spring/integration/scala/dsl/DSLUsageTests.scala#L87)

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)