@SuppressWarnings({"unchecked", "rawtypes"})
	@Before
	public void setUp() {
		messageBus.setCodec(new PojoCodec(new TupleKryoRegistrar()));
	}
@author Gary Russell
@author David Turanski
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/bus/MessageBusSupportTests.java