This is the sample code for PubSubReactiveFactory. It does not, however, explain its usage with ChannelAdapter.
PubSubReactiveFactory
ChannelAdapter