@Test
public void testSubmitTopology() {

	ThreadsEngine.submitTopology(topology, numThreads);
	new Verifications() {{
	    topology.run(); times=1;
	}};
	assertEquals("Number of threads is not set correctly.", numThreads,
			ThreadsEngine.getNumberOfThreads(),0);
}