Package com.flowable.agent.engine.impl.eventregistry

Class AgentEventRegistryEventConsumer

java.lang.Object

org.flowable.eventregistry.impl.consumer.BaseEventRegistryEventConsumer

com.flowable.agent.engine.impl.eventregistry.AgentEventRegistryEventConsumer

All Implemented Interfaces:

org.flowable.eventregistry.api.EventRegistryEventConsumer

public class AgentEventRegistryEventConsumer
extends org.flowable.eventregistry.impl.consumer.BaseEventRegistryEventConsumer

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected AgentEngineConfiguration	agentEngineConfiguration

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

commandExecutor, engingeConfiguration

Constructor Summary

Constructors

Constructor	Description
AgentEventRegistryEventConsumer(AgentEngineConfiguration agentEngineConfiguration)

Method Summary

Modifier and Type	Method	Description
protected org.flowable.eventsubscription.api.EventSubscriptionQuery	createEventSubscriptionQuery()
protected org.flowable.eventregistry.api.EventRegistryProcessingInfo	eventReceived(org.flowable.eventregistry.api.runtime.EventInstance eventInstance)
String	findDefinitionKeyById(String definitionId)
String	getConsumerKey()
protected boolean	handleEventSubscription(org.flowable.eventsubscription.api.EventSubscription eventSubscription, org.flowable.eventregistry.api.runtime.EventInstance eventInstance)

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

eventReceived, findDefinitionKeyById, findEventSubscriptions, generateCorrelationKey, generateCorrelationKeys, getCorrelationKeyWithAllParameters, getEventRegistry

Methods inherited from class java.lang.Object

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

Field Details

agentEngineConfiguration

protected AgentEngineConfiguration agentEngineConfiguration

Constructor Details

AgentEventRegistryEventConsumer

public AgentEventRegistryEventConsumer(AgentEngineConfiguration agentEngineConfiguration)

Method Details

getConsumerKey

public String getConsumerKey()

findDefinitionKeyById

public String findDefinitionKeyById(String definitionId)

Specified by:

findDefinitionKeyById in class org.flowable.eventregistry.impl.consumer.BaseEventRegistryEventConsumer

eventReceived

protected org.flowable.eventregistry.api.EventRegistryProcessingInfo eventReceived(org.flowable.eventregistry.api.runtime.EventInstance eventInstance)

Specified by:

eventReceived in class org.flowable.eventregistry.impl.consumer.BaseEventRegistryEventConsumer

handleEventSubscription

protected boolean handleEventSubscription(org.flowable.eventsubscription.api.EventSubscription eventSubscription,
 org.flowable.eventregistry.api.runtime.EventInstance eventInstance)

createEventSubscriptionQuery

protected org.flowable.eventsubscription.api.EventSubscriptionQuery createEventSubscriptionQuery()

Specified by:

createEventSubscriptionQuery in class org.flowable.eventregistry.impl.consumer.BaseEventRegistryEventConsumer