@Override
	protected MessageBus getMessageBus() throws Exception {
		LocalMessageBus bus = new LocalMessageBus();
		GenericApplicationContext applicationContext = new GenericApplicationContext();
		applicationContext.getBeanFactory().registerSingleton(
				IntegrationUtils.INTEGRATION_MESSAGE_BUILDER_FACTORY_BEAN_NAME,
				new DefaultMessageBuilderFactory());
		applicationContext.refresh();
		bus.setApplicationContext(applicationContext);
		bus.setExecutorCorePoolSize(2);
		bus.setExecutorMaxPoolSize(10);
		bus.setExecutorKeepAliveSeconds(59);
		bus.setExecutorQueueSize(Integer.MAX_VALUE - 1);
		bus.afterPropertiesSet();
		return bus;
	}
@author Gary Russell
@author David Turanski
@since 1.0
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/bus/local/LocalMessageBusTests.java