diff --git a/src/com/idcanet/foei/core/impl/EventExecutorImpl.java b/src/com/idcanet/foei/core/impl/EventExecutorImpl.java index 85539b9..123bbf4 100644 --- a/src/com/idcanet/foei/core/impl/EventExecutorImpl.java +++ b/src/com/idcanet/foei/core/impl/EventExecutorImpl.java @@ -98,18 +98,20 @@ public class EventExecutorImpl implements EventExecutor { ready = false; try { FoeiProcess foeiProcess = FoeiProcessFactory.getFoeiProcess(); - eventPort.addEventsPassed(); if(eventPort.getEventPortType()==EventPortType.input) { EventInput eventInput = (EventInput)eventPort.getEventObject(); + eventPort.addEventsPassed(); // inc input port eventInput.doEvent(eventPort,eventObject); return; } if(eventPort.getEventPortType()==EventPortType.output) { + eventPort.addEventsPassed(); // inc output port List bindings = foeiProcess.getBindings(eventPort); for(EventPort port:bindings) { EventInput eventInput = (EventInput)port.getEventObject(); if(port.isImmediate()) { logger.finer("Executing event of: "+port.getEventObject()+" port:"+port.getName()+" object: "+eventObject); + port.addEventsPassed(); // inc Immediate import port eventInput.doEvent(port,eventObject); } else { logger.finest("Adding event to event queue");