  @Test
  public void testRun() {

    topology.addEntranceProcessingItem(entrancePi);

    new Expectations() {
      {
        entrancePi.getProcessor();
        result = entranceProcessor;
        entranceProcessor.onCreate(anyInt);

        entrancePi.startSendingEvents();
      }
    };
    topology.run();
  }