@BeforeClass
	@SuppressWarnings({"unchecked", "rawtypes"})
	public static void initMessageBus() {
		TestMessageBus messageBus = new TestMessageBus();
		messageBus.setCodec(new PojoCodec(new TupleKryoRegistrar()));
		messageBusSupport = messageBus;
	}
Performance benchmark tests for {@link MessageBusSupport}
@author David Turanski
spring-xd-benchmark/src/test/java/org/springframework/xd/dirt/integration/bus/MessageBusSupportBenchmarkTests.java