@Override
	public synchronized boolean isRunning() {
		return this.running;
	}
Add tap channel to the module's output channel.
Also, bind the tap channel to the message bus.
spring-xd-dirt/src/main/java/org/springframework/xd/dirt/plugins/spark/streaming/MessageBusSender.java