com.qbpsimulator.engine

Class EventProcessor

java.lang.Object

com.qbpsimulator.engine.EventProcessor

All Implemented Interfaces:

IEventProcessor

public class EventProcessor
extends Object
implements IEventProcessor

Event Processor class to maintain the queue of events to complete.

Author:

Madis Abel

Constructor Summary

Constructors

Constructor and Description
EventProcessor(BPSimulator simulationInstance) Main constructor.

Method Summary

Modifier and Type	Method and Description
IProcessLogger	getProcessLogger()
IProcessScheduler	getProcessScheduler()
ProcessActivityCollaboration	getRegisteredMessage(String eventId) Returns already created instance of a message event which was discarded if there exist one and discards the new one.
void	notifyCollaboration(ProcessActivityCollaboration collaboration) Notify event processor of an inbound collaboration
void	notifyStartedActivities(ProcessActivity[] enabledActivities) Enables list of activities in a process instance.
void	processEvents() Starts processing event from the queue.
void	setProcessLogger(IProcessLogger processLogger)
void	setProcessScheduler(IProcessScheduler processScheduler)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventProcessor

public EventProcessor(BPSimulator simulationInstance)

Main constructor. Initializes queue and maps.

Method Detail

notifyStartedActivities

public void notifyStartedActivities(ProcessActivity[] enabledActivities)
                             throws BPSimulatorException

Description copied from interface: IEventProcessor

Enables list of activities in a process instance.

Specified by:

notifyStartedActivities in interface IEventProcessor

Parameters:

enabledActivities - array of activities to enable

Throws:

BPSimulatorException

notifyCollaboration

public void notifyCollaboration(ProcessActivityCollaboration collaboration)
                         throws BPSimulatorException

Description copied from interface: IEventProcessor

Notify event processor of an inbound collaboration

Specified by:

notifyCollaboration in interface IEventProcessor

Throws:

BPSimulatorException

getProcessScheduler

public IProcessScheduler getProcessScheduler()

setProcessScheduler

public void setProcessScheduler(IProcessScheduler processScheduler)

processEvents

public void processEvents()
                   throws BPSimulatorException,
                          InterruptedException

Description copied from interface: IEventProcessor

Starts processing event from the queue.

Specified by:

processEvents in interface IEventProcessor

Throws:

BPSimulatorException

InterruptedException

setProcessLogger

public void setProcessLogger(IProcessLogger processLogger)

getProcessLogger

public IProcessLogger getProcessLogger()

getRegisteredMessage

public ProcessActivityCollaboration getRegisteredMessage(String eventId)

Description copied from interface: IEventProcessor

Returns already created instance of a message event which was discarded if there exist one and discards the new one.

Specified by:

getRegisteredMessage in interface IEventProcessor

Parameters:

eventId - Source event with the same associated Activity which one to replace if message has been registered

Returns:

Previously discarded event.