@Override
					public void handleMessage(Message<?> message) throws MessagingException {
						messageReceived.set(message);
					}
@author Mark Fisher
@author Jennifer Hickey
@author Gary Russell
@author David Turanski
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/plugins/stream/StreamPluginTests.java