@Override
			public void handleMessage(Message<?> message) throws MessagingException {
				try {
					Thread.sleep(100);
				}
				catch (InterruptedException e) {
					Thread.currentThread().interrupt();
				}
				stepsIn.send(MessageBuilder.fromMessage(message)
						.setHeader("thread", Thread.currentThread().getName())
						.build());
			}
@author Michael Minella
@author Gunnar Hillert
@author Gary Russell
@author Ilayaperumal Gopinathan
@author David Turanski
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/plugins/job/JobPluginTests.java