org.flowable.eventregistry.impl.model

Class InboundChannelDefinitionBuilderImpl.InboundRabbitChannelBuilderImpl

java.lang.Object

org.flowable.eventregistry.impl.model.InboundChannelDefinitionBuilderImpl.InboundRabbitChannelBuilderImpl

All Implemented Interfaces:

InboundChannelModelBuilder.InboundRabbitChannelBuilder

Enclosing class:

InboundChannelDefinitionBuilderImpl

public static class InboundChannelDefinitionBuilderImpl.InboundRabbitChannelBuilderImpl
extends Object
implements InboundChannelModelBuilder.InboundRabbitChannelBuilder

Field Summary

Fields

Modifier and Type	Field and Description
protected InboundChannelDefinitionBuilderImpl	channelDefinitionBuilder
protected EventRepositoryService	eventRepositoryService
protected RabbitInboundChannelModel	rabbitChannel

Constructor Summary

Constructors

Constructor and Description
InboundRabbitChannelBuilderImpl(RabbitInboundChannelModel rabbitChannel, EventRepositoryService eventRepositoryService, InboundChannelDefinitionBuilderImpl channelDefinitionBuilder)

Method Summary

Modifier and Type	Method and Description
InboundChannelModelBuilder.InboundRabbitChannelBuilder	ackMode(String ackMode) Sets the AckMode (e.g.
InboundChannelModelBuilder.InboundRabbitChannelBuilder	admin(String admin) Bean name of a org.springframework.amqp.rabbit.core.RabbitAdmin instance.
InboundChannelModelBuilder.InboundRabbitChannelBuilder	concurrency(String concurrency) Sets the concurrency for the listener.
InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder	eventProcessingPipeline() Continue building the InboundChannelModel by configuring the next parts (if any).
InboundChannelModelBuilder.InboundRabbitChannelBuilder	exclusive(boolean exclusive) Sets whether this adapter will be the only consumer of messages of the provided queue(s).
InboundChannelModelBuilder.InboundRabbitChannelBuilder	executor(String executor) Bean name of a TaskExecutor instance used to process incoming messages.
InboundChannelModelBuilder.InboundRabbitChannelBuilder	priority(String priority) Sets the priority of this adapter.

Methods inherited from class java.lang.Object

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

Field Detail

eventRepositoryService

protected final EventRepositoryService eventRepositoryService

channelDefinitionBuilder

protected final InboundChannelDefinitionBuilderImpl channelDefinitionBuilder

rabbitChannel

protected RabbitInboundChannelModel rabbitChannel

Constructor Detail

InboundRabbitChannelBuilderImpl

public InboundRabbitChannelBuilderImpl(RabbitInboundChannelModel rabbitChannel,
                                       EventRepositoryService eventRepositoryService,
                                       InboundChannelDefinitionBuilderImpl channelDefinitionBuilder)

Method Detail

exclusive

public InboundChannelModelBuilder.InboundRabbitChannelBuilder exclusive(boolean exclusive)

Description copied from interface: InboundChannelModelBuilder.InboundRabbitChannelBuilder

Sets whether this adapter will be the only consumer of messages of the provided queue(s). See the Spring Rabbit docs for more info.

Specified by:

exclusive in interface InboundChannelModelBuilder.InboundRabbitChannelBuilder

priority

public InboundChannelModelBuilder.InboundRabbitChannelBuilder priority(String priority)

Description copied from interface: InboundChannelModelBuilder.InboundRabbitChannelBuilder

Sets the priority of this adapter. See the Spring Rabbit docs for more info.

Specified by:

priority in interface InboundChannelModelBuilder.InboundRabbitChannelBuilder

admin

public InboundChannelModelBuilder.InboundRabbitChannelBuilder admin(String admin)

Description copied from interface: InboundChannelModelBuilder.InboundRabbitChannelBuilder

Bean name of a org.springframework.amqp.rabbit.core.RabbitAdmin instance. See the Spring Rabbit docs for more info.

Specified by:

admin in interface InboundChannelModelBuilder.InboundRabbitChannelBuilder

concurrency

public InboundChannelModelBuilder.InboundRabbitChannelBuilder concurrency(String concurrency)

Description copied from interface: InboundChannelModelBuilder.InboundRabbitChannelBuilder

Sets the concurrency for the listener. See the Spring JMS docs for more info.

Specified by:

concurrency in interface InboundChannelModelBuilder.InboundRabbitChannelBuilder

executor

public InboundChannelModelBuilder.InboundRabbitChannelBuilder executor(String executor)

Description copied from interface: InboundChannelModelBuilder.InboundRabbitChannelBuilder

Bean name of a TaskExecutor instance used to process incoming messages.

Specified by:

executor in interface InboundChannelModelBuilder.InboundRabbitChannelBuilder

ackMode

public InboundChannelModelBuilder.InboundRabbitChannelBuilder ackMode(String ackMode)

Description copied from interface: InboundChannelModelBuilder.InboundRabbitChannelBuilder

Sets the AckMode (e.g. NONE/MANUAL/AUTO). See the Spring JMS docs for more info.

Specified by:

ackMode in interface InboundChannelModelBuilder.InboundRabbitChannelBuilder

eventProcessingPipeline

public InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder eventProcessingPipeline()

Description copied from interface: InboundChannelModelBuilder.InboundRabbitChannelBuilder

Continue building the InboundChannelModel by configuring the next parts (if any).

Specified by:

eventProcessingPipeline in interface InboundChannelModelBuilder.InboundRabbitChannelBuilder