NamedChannelSource source = new SingleNodeNamedChannelSourceFactory(messageBus).createNamedChannelSource("queue:producer");
NamedChannelSink sink = new SingleNodeNamedChannelSinkFactory(messageBus).createNamedChannelSink("queue:consumer");
source.sendPayload("hello");
String result = (String) sink.receivePayload(RECEIVE_TIMEOUT);
assertEquals("HELLO", result);
source.sendPayload("a");
result = (String) sink.receivePayload(RECEIVE_TIMEOUT);
assertNull(result);