public interface EventRegistry
InboundEventChannelAdapter
and then passed through as a event registry event.| Modifier and Type | Method and Description |
|---|---|
void |
eventReceived(InboundChannelModel channelModel,
String 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.
|
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)
Send out an event.
|
void |
sendEventToConsumers(EventRegistryEvent eventRegistryEvent)
Send an event to all the registered event consumers.
|
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 setInboundEventProcessor(InboundEventProcessor inboundEventProcessor)
InboundEventProcessor is responsible for handling any new event.
The event registry will simply pass any event it receives to this instance.void setOutboundEventProcessor(OutboundEventProcessor outboundEventProcessor)
OutboundEventProcessor is responsible for handling sending out events.
The event registry will simply pass any event it needs to send to this instance.void registerEventRegistryEventConsumer(EventRegistryEventConsumer eventRegistryEventBusConsumer)
EventRegistryEventConsumer instance (a consumer of event registry events which
is created by any of the engines).void removeFlowableEventRegistryEventConsumer(EventRegistryEventConsumer eventRegistryEventBusConsumer)
String generateKey(Map<String,Object> data)
data - data information used to generate the key (must not be null)void eventReceived(InboundChannelModel channelModel, String event)
void sendEventToConsumers(EventRegistryEvent eventRegistryEvent)
void sendEventOutbound(EventInstance eventInstance)
EventModel will be used to
decide which channel (and pipeline) will be usedCopyright © 2020 Flowable. All rights reserved.