@Test
	public void testProps() throws Exception {
		LocalMessageBus bus = (LocalMessageBus) getMessageBus();
		ThreadPoolTaskExecutor exec = TestUtils.getPropertyValue(bus, "executor", ThreadPoolTaskExecutor.class);
		assertEquals(2, exec.getCorePoolSize());
		assertEquals(10, exec.getMaxPoolSize());
		assertEquals(59, exec.getKeepAliveSeconds());
		assertEquals(Integer.MAX_VALUE - 1, TestUtils.getPropertyValue(exec, "queueCapacity"));
	}
@author Gary Russell
@author David Turanski
@since 1.0
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/integration/bus/local/LocalMessageBusTests.java