SimpleComponentFactory implements ComponentFactory { public EntranceProcessingItem createEntrancePi(EntranceProcessor processor) { return new SimpleEntranceProcessingItem(processor); }  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 testCreateEntrancePi() { EntranceProcessingItem entrancePi = factory.createEntrancePi(entranceProcessor); assertNotNull("EntranceProcessingItem created is null.",entrancePi); assertEquals("EntranceProcessingItem created is not a SimpleEntranceProcessingItem.",SimpleEntranceProcessingItem.class,entrancePi.getClass()); assertSame("EntranceProcessor is not set correctly.",entranceProcessor, entrancePi.getProcessor()); }