@Override
	@SuppressWarnings("rawtypes")
	public synchronized void send(Message message) {
		this.outputChannel.send(message);
	}
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