Package org.flowable.eventregistry.impl

Class DefaultEventRegistry

java.lang.Object

org.flowable.eventregistry.impl.DefaultEventRegistry

All Implemented Interfaces:

EventRegistry

public class DefaultEventRegistry
extends Object
implements EventRegistry

Author:

Joram Barrez

Field Summary

Fields

Modifier and Type	Field	Description
protected CorrelationKeyGenerator<Map<String,Object>>	correlationKeyGenerator
protected EventRegistryEngineConfiguration	engineConfiguration
protected InboundEventProcessor	inboundEventProcessor
protected final org.slf4j.Logger	logger
protected OutboundEventProcessor	outboundEventProcessor
protected OutboundEventProcessor	systemOutboundEventProcessor

Constructor Summary

Constructors

Constructor	Description
DefaultEventRegistry(EventRegistryEngineConfiguration engineConfiguration)

Method Summary

Modifier and Type	Method	Description
void	eventReceived(InboundChannelModel channelModel, String event)
void	eventReceived(InboundChannelModel channelModel, InboundEvent event)	Events received in adapters should call this method to process events.
String	generateKey(Map<String,Object> data)	Method to generate the unique key used to correlate an event.
OutboundEventProcessor	getSystemOutboundEventProcessor()
void	registerEventRegistryEventConsumer(EventRegistryEventConsumer eventRegistryEventBusConsumer)	Registers a EventRegistryEventConsumer instance (a consumer of event registry events which is created by any of the engines).
void	removeFlowableEventRegistryEventConsumer(EventRegistryEventConsumer eventRegistryEventBusConsumer)	Removes the event consumer from the event registry
void	sendEventOutbound(EventInstance eventInstance, Collection<ChannelModel> channelModels)	Send out the eventInstance via the given channelModel(s).
void	sendEventToConsumers(EventRegistryEvent eventRegistryEvent)	Send an event to all the registered event consumers.
void	sendSystemEventOutbound(EventInstance eventInstance)	Send out the eventInstance via the given system OutboundEventProcessor.
void	setInboundEventProcessor(InboundEventProcessor inboundEventProcessor)	The InboundEventProcessor is responsible for handling any new event.
void	setOutboundEventProcessor(OutboundEventProcessor outboundEventProcessor)	The OutboundEventProcessor is responsible for handling sending out events.
void	setSystemOutboundEventProcessor(OutboundEventProcessor systemOutboundEventProcessor)	The OutboundEventProcessor is responsible for handling sending system out events.

Methods inherited from class java.lang.Object

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

Field Details

logger

protected final org.slf4j.Logger logger

engineConfiguration

protected EventRegistryEngineConfiguration engineConfiguration

correlationKeyGenerator

protected CorrelationKeyGenerator<Map<String,Object>> correlationKeyGenerator

inboundEventProcessor

protected InboundEventProcessor inboundEventProcessor

outboundEventProcessor

protected OutboundEventProcessor outboundEventProcessor

systemOutboundEventProcessor

protected OutboundEventProcessor systemOutboundEventProcessor

Constructor Details

DefaultEventRegistry

public DefaultEventRegistry(EventRegistryEngineConfiguration engineConfiguration)

Method Details

setInboundEventProcessor

public void setInboundEventProcessor(InboundEventProcessor inboundEventProcessor)

Description copied from interface: EventRegistry

The InboundEventProcessor is responsible for handling any new event. The event registry will simply pass any event it receives to this instance.

Specified by:

setInboundEventProcessor in interface EventRegistry

setOutboundEventProcessor

public void setOutboundEventProcessor(OutboundEventProcessor outboundEventProcessor)

Description copied from interface: EventRegistry

The OutboundEventProcessor is responsible for handling sending out events. The event registry will simply pass any event it needs to send to this instance.

Specified by:

setOutboundEventProcessor in interface EventRegistry

getSystemOutboundEventProcessor

public OutboundEventProcessor getSystemOutboundEventProcessor()

Specified by:

getSystemOutboundEventProcessor in interface EventRegistry

setSystemOutboundEventProcessor

public void setSystemOutboundEventProcessor(OutboundEventProcessor systemOutboundEventProcessor)

Description copied from interface: EventRegistry

The OutboundEventProcessor is responsible for handling sending system out events. The event registry will simply pass any event it needs to send to this instance.

Specified by:

setSystemOutboundEventProcessor in interface EventRegistry

eventReceived

public void eventReceived(InboundChannelModel channelModel,
 String event)

Specified by:

eventReceived in interface EventRegistry

eventReceived

public void eventReceived(InboundChannelModel channelModel,
 InboundEvent event)

Description copied from interface: EventRegistry

Events received in adapters should call this method to process events.

Specified by:

eventReceived in interface EventRegistry

sendEventToConsumers

public void sendEventToConsumers(EventRegistryEvent eventRegistryEvent)

Description copied from interface: EventRegistry

Send an event to all the registered event consumers.

Specified by:

sendEventToConsumers in interface EventRegistry

sendSystemEventOutbound

public void sendSystemEventOutbound(EventInstance eventInstance)

Description copied from interface: EventRegistry

Send out the eventInstance via the given system OutboundEventProcessor.

Specified by:

sendSystemEventOutbound in interface EventRegistry

sendEventOutbound

public void sendEventOutbound(EventInstance eventInstance,
 Collection<ChannelModel> channelModels)

Description copied from interface: EventRegistry

Send out the eventInstance via the given channelModel(s).

Specified by:

sendEventOutbound in interface EventRegistry

registerEventRegistryEventConsumer

public void registerEventRegistryEventConsumer(EventRegistryEventConsumer eventRegistryEventBusConsumer)

Description copied from interface: EventRegistry

Registers a EventRegistryEventConsumer instance (a consumer of event registry events which is created by any of the engines).

Specified by:

registerEventRegistryEventConsumer in interface EventRegistry

removeFlowableEventRegistryEventConsumer

public void removeFlowableEventRegistryEventConsumer(EventRegistryEventConsumer eventRegistryEventBusConsumer)

Description copied from interface: EventRegistry

Removes the event consumer from the event registry

Specified by:

removeFlowableEventRegistryEventConsumer in interface EventRegistry

generateKey

public String generateKey(Map<String,Object> data)

Description copied from interface: EventRegistry

Method to generate the unique key used to correlate an event.

Specified by:

generateKey in interface EventRegistry

Parameters:

data - data information used to generate the key (must not be null)

Returns:

a unique string correlating the event based on the information supplied