Package org.flowable.eventregistry.impl.pipeline

Class DefaultInboundEventProcessingPipeline<T>

java.lang.Object

org.flowable.eventregistry.impl.pipeline.DefaultInboundEventProcessingPipeline<T>

All Implemented Interfaces:

InboundEventProcessingPipeline

public class DefaultInboundEventProcessingPipeline<T>
extends Object
implements InboundEventProcessingPipeline

Author:

Joram Barrez, Filip Hrisafov

Field Summary

Fields

Modifier and Type	Field	Description
protected EventRepositoryService	eventRepositoryService
protected InboundEventDeserializer<T>	inboundEventDeserializer
protected InboundEventFilter<T>	inboundEventFilter
protected InboundEventKeyDetector<T>	inboundEventKeyDetector
protected InboundEventPayloadExtractor<T>	inboundEventPayloadExtractor
protected InboundEventTenantDetector<T>	inboundEventTenantDetector
protected InboundEventTransformer	inboundEventTransformer
protected final org.slf4j.Logger	logger

Constructor Summary

Constructors

Constructor

Description

DefaultInboundEventProcessingPipeline(EventRepositoryService eventRepositoryService, InboundEventDeserializer<T> inboundEventDeserializer, InboundEventFilter<T> inboundEventFilter, InboundEventKeyDetector<T> inboundEventKeyDetector, InboundEventTenantDetector<T> inboundEventTenantDetector, InboundEventPayloadExtractor<T> inboundEventPayloadExtractor, InboundEventTransformer inboundEventTransformer)

Method Summary

Modifier and Type	Method	Description
T	deserialize(Object rawEvent)
String	detectEventDefinitionKey(FlowableEventInfo<T> event)
Collection<EventPayloadInstance>	extractPayload(EventModel eventDefinition, FlowableEventInfo<T> event)
InboundEventDeserializer<T>	getInboundEventDeserializer()
InboundEventKeyDetector<T>	getInboundEventKeyDetector()
InboundEventPayloadExtractor<T>	getInboundEventPayloadExtractor()
InboundEventTenantDetector<T>	getInboundEventTenantDetector()
InboundEventTransformer	getInboundEventTransformer()
Collection<EventRegistryEvent>	run(InboundChannelModel inboundChannel, InboundEvent inboundEvent)
void	setInboundEventDeserializer(InboundEventDeserializer<T> inboundEventDeserializer)
void	setInboundEventKeyDetector(InboundEventKeyDetector<T> inboundEventKeyDetector)
void	setInboundEventPayloadExtractor(InboundEventPayloadExtractor<T> inboundEventPayloadExtractor)
void	setInboundEventTenantDetector(InboundEventTenantDetector<T> inboundEventTenantDetector)
void	setInboundEventTransformer(InboundEventTransformer inboundEventTransformer)
Collection<EventRegistryEvent>	transform(EventInstance eventInstance)

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

eventRepositoryService

protected EventRepositoryService eventRepositoryService

inboundEventDeserializer

protected InboundEventDeserializer<T> inboundEventDeserializer

inboundEventFilter

protected InboundEventFilter<T> inboundEventFilter

inboundEventKeyDetector

protected InboundEventKeyDetector<T> inboundEventKeyDetector

inboundEventTenantDetector

protected InboundEventTenantDetector<T> inboundEventTenantDetector

inboundEventPayloadExtractor

protected InboundEventPayloadExtractor<T> inboundEventPayloadExtractor

inboundEventTransformer

protected InboundEventTransformer inboundEventTransformer

Constructor Details

DefaultInboundEventProcessingPipeline

public DefaultInboundEventProcessingPipeline(EventRepositoryService eventRepositoryService,
 InboundEventDeserializer<T> inboundEventDeserializer,
 InboundEventFilter<T> inboundEventFilter,
 InboundEventKeyDetector<T> inboundEventKeyDetector,
 InboundEventTenantDetector<T> inboundEventTenantDetector,
 InboundEventPayloadExtractor<T> inboundEventPayloadExtractor,
 InboundEventTransformer inboundEventTransformer)

Method Details

run

public Collection<EventRegistryEvent> run(InboundChannelModel inboundChannel,
 InboundEvent inboundEvent)

Specified by:

run in interface InboundEventProcessingPipeline

deserialize

public T deserialize(Object rawEvent)

detectEventDefinitionKey

public String detectEventDefinitionKey(FlowableEventInfo<T> event)

extractPayload

public Collection<EventPayloadInstance> extractPayload(EventModel eventDefinition,
 FlowableEventInfo<T> event)

transform

public Collection<EventRegistryEvent> transform(EventInstance eventInstance)

getInboundEventDeserializer

public InboundEventDeserializer<T> getInboundEventDeserializer()

setInboundEventDeserializer

public void setInboundEventDeserializer(InboundEventDeserializer<T> inboundEventDeserializer)

getInboundEventKeyDetector

public InboundEventKeyDetector<T> getInboundEventKeyDetector()

setInboundEventKeyDetector

public void setInboundEventKeyDetector(InboundEventKeyDetector<T> inboundEventKeyDetector)

getInboundEventTenantDetector

public InboundEventTenantDetector<T> getInboundEventTenantDetector()

setInboundEventTenantDetector

public void setInboundEventTenantDetector(InboundEventTenantDetector<T> inboundEventTenantDetector)

getInboundEventPayloadExtractor

public InboundEventPayloadExtractor<T> getInboundEventPayloadExtractor()

setInboundEventPayloadExtractor

public void setInboundEventPayloadExtractor(InboundEventPayloadExtractor<T> inboundEventPayloadExtractor)

getInboundEventTransformer

public InboundEventTransformer getInboundEventTransformer()

setInboundEventTransformer

public void setInboundEventTransformer(InboundEventTransformer inboundEventTransformer)