org.flowable.engine.impl.eventregistry

Class BpmnEventRegistryEventConsumer

java.lang.Object

org.flowable.eventregistry.impl.consumer.BaseEventRegistryEventConsumer

org.flowable.engine.impl.eventregistry.BpmnEventRegistryEventConsumer

All Implemented Interfaces:

EventRegistryEventConsumer

public class BpmnEventRegistryEventConsumer
extends BaseEventRegistryEventConsumer

Field Summary

Fields

Modifier and Type	Field and Description
protected ProcessEngineConfigurationImpl	processEngineConfiguration

Fields inherited from class org.flowable.eventregistry.impl.consumer.BaseEventRegistryEventConsumer

commandExecutor, engingeConfiguration

Constructor Summary

Constructors

Constructor and Description
BpmnEventRegistryEventConsumer(ProcessEngineConfigurationImpl processEngineConfiguration)

Method Summary

Modifier and Type	Method and Description
protected EventSubscriptionQuery	createEventSubscriptionQuery()
protected void	eventReceived(EventInstance eventInstance)
String	getConsumerKey()
protected String	getStartCorrelationConfiguration(EventSubscription eventSubscription)
protected void	handleEventSubscription(RuntimeService runtimeService, EventSubscription eventSubscription, EventInstance eventInstance, Collection<CorrelationKey> correlationKeys)

Methods inherited from class org.flowable.eventregistry.impl.consumer.BaseEventRegistryEventConsumer

eventReceived, findEventSubscriptions, generateCorrelationKey, generateCorrelationKeys, getCorrelationKeyWithAllParameters, getEventRegistry

Methods inherited from class java.lang.Object

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

Field Detail

processEngineConfiguration

protected ProcessEngineConfigurationImpl processEngineConfiguration

Constructor Detail

BpmnEventRegistryEventConsumer

public BpmnEventRegistryEventConsumer(ProcessEngineConfigurationImpl processEngineConfiguration)

Method Detail

getConsumerKey

public String getConsumerKey()

eventReceived

protected void eventReceived(EventInstance eventInstance)

Specified by:

eventReceived in class BaseEventRegistryEventConsumer

handleEventSubscription

protected void handleEventSubscription(RuntimeService runtimeService,
                                       EventSubscription eventSubscription,
                                       EventInstance eventInstance,
                                       Collection<CorrelationKey> correlationKeys)

getStartCorrelationConfiguration

protected String getStartCorrelationConfiguration(EventSubscription eventSubscription)

createEventSubscriptionQuery

protected EventSubscriptionQuery createEventSubscriptionQuery()

Specified by:

createEventSubscriptionQuery in class BaseEventRegistryEventConsumer