SimpleComponentFactory implements ComponentFactory { public Topology createTopology(String topoName) { return new SimpleTopology(topoName); }  ProcessingItem createPi(Processor processor, int paralellism); ProcessingItem createPi(Processor processor); EntranceProcessingItem createEntrancePi(EntranceProcessor processor); Stream createStream(IProcessingItem sourcePi); Topology createTopology(String topoName);  }
@Test public void testCreateTopology() { Topology topology = factory.createTopology(topoName); assertNotNull("Topology created is null.",topology); assertEquals("Topology created is not a SimpleTopology.",SimpleTopology.class,topology.getClass()); }