Package org.flowable.eventregistry.impl

Class SystemOutboundEventProcessor<T>

java.lang.Object

org.flowable.eventregistry.impl.SystemOutboundEventProcessor<T>

All Implemented Interfaces:

OutboundEventProcessor

public class SystemOutboundEventProcessor<T>
extends Object
implements OutboundEventProcessor

Author:

Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected OutboundEventChannelAdapter<T>	outboundEventChannelAdapter
protected OutboundEventProcessingPipeline<T>	outboundEventProcessingPipeline

Constructor Summary

Constructors

Constructor	Description
SystemOutboundEventProcessor(OutboundEventChannelAdapter<T> outboundEventChannelAdapter, OutboundEventProcessingPipeline<T> outboundEventProcessingPipeline)

Method Summary

Modifier and Type	Method	Description
OutboundEventChannelAdapter<T>	getOutboundEventChannelAdapter()
OutboundEventProcessingPipeline<T>	getOutboundEventProcessingPipeline()
void	sendEvent(EventInstance eventInstance, Collection<ChannelModel> channelModels)
void	setOutboundEventChannelAdapter(OutboundEventChannelAdapter<T> outboundEventChannelAdapter)
void	setOutboundEventProcessingPipeline(OutboundEventProcessingPipeline<T> outboundEventProcessingPipeline)

Methods inherited from class java.lang.Object

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

Field Details

outboundEventChannelAdapter

protected OutboundEventChannelAdapter<T> outboundEventChannelAdapter

outboundEventProcessingPipeline

protected OutboundEventProcessingPipeline<T> outboundEventProcessingPipeline

Constructor Details

SystemOutboundEventProcessor

public SystemOutboundEventProcessor(OutboundEventChannelAdapter<T> outboundEventChannelAdapter,
 OutboundEventProcessingPipeline<T> outboundEventProcessingPipeline)

Method Details

sendEvent

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

Specified by:

sendEvent in interface OutboundEventProcessor

getOutboundEventChannelAdapter

public OutboundEventChannelAdapter<T> getOutboundEventChannelAdapter()

setOutboundEventChannelAdapter

public void setOutboundEventChannelAdapter(OutboundEventChannelAdapter<T> outboundEventChannelAdapter)

getOutboundEventProcessingPipeline

public OutboundEventProcessingPipeline<T> getOutboundEventProcessingPipeline()

setOutboundEventProcessingPipeline

public void setOutboundEventProcessingPipeline(OutboundEventProcessingPipeline<T> outboundEventProcessingPipeline)