org.flowable.eventregistry.impl.model

Class InboundChannelDefinitionBuilderImpl

java.lang.Object

org.flowable.eventregistry.impl.model.InboundChannelDefinitionBuilderImpl

All Implemented Interfaces:

InboundChannelModelBuilder

public class InboundChannelDefinitionBuilderImpl
extends Object
implements InboundChannelModelBuilder

Author:

Joram Barrez, Filip Hrisafov

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InboundChannelDefinitionBuilderImpl.InboundEventDefinitionKeyDetectorBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundEventKeyJsonDetectorBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundEventKeyXmlDetectorBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundEventPayloadExtractorBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundEventPayloadJsonExtractorBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundEventPayloadXmlExtractorBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundEventProcessingPipelineBuilderImpl<T>
static class	InboundChannelDefinitionBuilderImpl.InboundEventTenantDetectorBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundEventTenantJsonDetectorBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundEventTenantXmlDetectorBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundEventTransformerBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundJmsChannelBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundKafkaChannelBuilderImpl
static class	InboundChannelDefinitionBuilderImpl.InboundRabbitChannelBuilderImpl

Nested classes/interfaces inherited from interface org.flowable.eventregistry.api.model.InboundChannelModelBuilder

InboundChannelModelBuilder.InboundEventKeyDetectorBuilder, InboundChannelModelBuilder.InboundEventKeyJsonDetectorBuilder, InboundChannelModelBuilder.InboundEventKeyXmlDetectorBuilder, InboundChannelModelBuilder.InboundEventPayloadExtractorBuilder, InboundChannelModelBuilder.InboundEventPayloadJsonExtractorBuilder, InboundChannelModelBuilder.InboundEventPayloadXmlExtractorBuilder, InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder, InboundChannelModelBuilder.InboundEventTenantDetectorBuilder, InboundChannelModelBuilder.InboundEventTenantJsonDetectorBuilder, InboundChannelModelBuilder.InboundEventTenantXmlDetectorBuilder, InboundChannelModelBuilder.InboundEventTransformerBuilder, InboundChannelModelBuilder.InboundJmsChannelBuilder, InboundChannelModelBuilder.InboundKafkaChannelBuilder, InboundChannelModelBuilder.InboundRabbitChannelBuilder

Field Summary

Fields

Modifier and Type	Field and Description
protected String	category
protected ChannelJsonConverter	channelJsonConverter
protected InboundChannelModel	channelModel
protected String	deploymentName
protected String	deploymentTenantId
protected EventRepositoryService	eventRepository
protected InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder	inboundEventProcessingPipelineBuilder
protected String	key
protected String	parentDeploymentId
protected String	resourceName

Constructor Summary

Constructors

Constructor and Description
InboundChannelDefinitionBuilderImpl(EventRepositoryService eventRepository, ChannelJsonConverter channelJsonConverter)

Method Summary

Modifier and Type	Method and Description
protected ChannelModel	buildChannelModel()
InboundChannelModelBuilder	category(String category) Set the category for the channel deployment.
InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder	channelAdapter(String delegateExpression) Sets a custom InboundEventChannelAdapter via a delegate expression.
EventDeployment	deploy() Creates the InboundChannelModel instance based on the configuration and registers it with the EventRepositoryService.
InboundChannelModelBuilder	deploymentName(String deploymentName) Set the name for the channel deployment.
InboundChannelModelBuilder	deploymentTenantId(String deploymentTenantId) Set the tenant id for the channel deployment.
InboundChannelModelBuilder.InboundJmsChannelBuilder	jmsChannelAdapter(String destinationName) Configures an adapter which will receive events using JMS.
InboundChannelModelBuilder.InboundKafkaChannelBuilder	kafkaChannelAdapter(String topic) Configures an adapter which receives events using Kafka.
InboundChannelModelBuilder	key(String key) Each channel needs to have a unique key to identity it.
InboundChannelModelBuilder	parentDeploymentId(String parentDeploymentId) Set the parent deployment id for the channel deployment.
InboundChannelModelBuilder.InboundRabbitChannelBuilder	rabbitChannelAdapter(String queueName) Configures an adapter which will receive events using a RabbitMQ.
InboundChannelModelBuilder	resourceName(String resourceName) Set the resource name for the channel model.

Methods inherited from class java.lang.Object

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

Field Detail

eventRepository

protected EventRepositoryService eventRepository

channelJsonConverter

protected ChannelJsonConverter channelJsonConverter

channelModel

protected InboundChannelModel channelModel

deploymentName

protected String deploymentName

resourceName

protected String resourceName

category

protected String category

parentDeploymentId

protected String parentDeploymentId

deploymentTenantId

protected String deploymentTenantId

key

protected String key

inboundEventProcessingPipelineBuilder

protected InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder inboundEventProcessingPipelineBuilder

Constructor Detail

InboundChannelDefinitionBuilderImpl

public InboundChannelDefinitionBuilderImpl(EventRepositoryService eventRepository,
                                           ChannelJsonConverter channelJsonConverter)

Method Detail

key

public InboundChannelModelBuilder key(String key)

Description copied from interface: InboundChannelModelBuilder

Each channel needs to have a unique key to identity it.

Specified by:

key in interface InboundChannelModelBuilder

deploymentName

public InboundChannelModelBuilder deploymentName(String deploymentName)

Description copied from interface: InboundChannelModelBuilder

Set the name for the channel deployment.

Specified by:

deploymentName in interface InboundChannelModelBuilder

resourceName

public InboundChannelModelBuilder resourceName(String resourceName)

Description copied from interface: InboundChannelModelBuilder

Set the resource name for the channel model.

Specified by:

resourceName in interface InboundChannelModelBuilder

category

public InboundChannelModelBuilder category(String category)

Description copied from interface: InboundChannelModelBuilder

Set the category for the channel deployment.

Specified by:

category in interface InboundChannelModelBuilder

parentDeploymentId

public InboundChannelModelBuilder parentDeploymentId(String parentDeploymentId)

Description copied from interface: InboundChannelModelBuilder

Set the parent deployment id for the channel deployment.

Specified by:

parentDeploymentId in interface InboundChannelModelBuilder

deploymentTenantId

public InboundChannelModelBuilder deploymentTenantId(String deploymentTenantId)

Description copied from interface: InboundChannelModelBuilder

Set the tenant id for the channel deployment.

Specified by:

deploymentTenantId in interface InboundChannelModelBuilder

channelAdapter

public InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder channelAdapter(String delegateExpression)

Description copied from interface: InboundChannelModelBuilder

Sets a custom InboundEventChannelAdapter via a delegate expression.

Specified by:

channelAdapter in interface InboundChannelModelBuilder

jmsChannelAdapter

public InboundChannelModelBuilder.InboundJmsChannelBuilder jmsChannelAdapter(String destinationName)

Description copied from interface: InboundChannelModelBuilder

Configures an adapter which will receive events using JMS.

Specified by:

jmsChannelAdapter in interface InboundChannelModelBuilder

rabbitChannelAdapter

public InboundChannelModelBuilder.InboundRabbitChannelBuilder rabbitChannelAdapter(String queueName)

Description copied from interface: InboundChannelModelBuilder

Configures an adapter which will receive events using a RabbitMQ.

Specified by:

rabbitChannelAdapter in interface InboundChannelModelBuilder

kafkaChannelAdapter

public InboundChannelModelBuilder.InboundKafkaChannelBuilder kafkaChannelAdapter(String topic)

Description copied from interface: InboundChannelModelBuilder

Configures an adapter which receives events using Kafka.

Specified by:

kafkaChannelAdapter in interface InboundChannelModelBuilder

deploy

public EventDeployment deploy()

Description copied from interface: InboundChannelModelBuilder

Creates the InboundChannelModel instance based on the configuration and registers it with the EventRepositoryService.

Specified by:

deploy in interface InboundChannelModelBuilder

buildChannelModel

protected ChannelModel buildChannelModel()