public static class InboundChannelDefinitionBuilderImpl.InboundJmsChannelBuilderImpl extends Object implements InboundChannelModelBuilder.InboundJmsChannelBuilder
| Modifier and Type | Field and Description |
|---|---|
protected InboundChannelDefinitionBuilderImpl |
channelDefinitionBuilder |
protected EventRepositoryService |
eventRepositoryService |
protected JmsInboundChannelModel |
jmsChannel |
| Constructor and Description |
|---|
InboundJmsChannelBuilderImpl(JmsInboundChannelModel jmsChannel,
EventRepositoryService eventRepositoryService,
InboundChannelDefinitionBuilderImpl channelDefinitionBuilder) |
| Modifier and Type | Method and Description |
|---|---|
InboundChannelModelBuilder.InboundJmsChannelBuilder |
concurrency(String concurrency)
Sets the concurrency for the listener (e.g "5-10").
|
InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder |
eventProcessingPipeline()
Continue building the
InboundChannelModel by configuring the next parts (if any). |
InboundChannelModelBuilder.InboundJmsChannelBuilder |
selector(String selector)
Set the JMS message selector, which can be used to filter
out incoming events.
|
InboundChannelModelBuilder.InboundJmsChannelBuilder |
subscription(String subscription)
Sets the JMS subscription.
|
protected final EventRepositoryService eventRepositoryService
protected final InboundChannelDefinitionBuilderImpl channelDefinitionBuilder
protected JmsInboundChannelModel jmsChannel
public InboundJmsChannelBuilderImpl(JmsInboundChannelModel jmsChannel, EventRepositoryService eventRepositoryService, InboundChannelDefinitionBuilderImpl channelDefinitionBuilder)
public InboundChannelModelBuilder.InboundJmsChannelBuilder selector(String selector)
InboundChannelModelBuilder.InboundJmsChannelBuilderselector in interface InboundChannelModelBuilder.InboundJmsChannelBuilderpublic InboundChannelModelBuilder.InboundJmsChannelBuilder subscription(String subscription)
InboundChannelModelBuilder.InboundJmsChannelBuildersubscription in interface InboundChannelModelBuilder.InboundJmsChannelBuilderpublic InboundChannelModelBuilder.InboundJmsChannelBuilder concurrency(String concurrency)
InboundChannelModelBuilder.InboundJmsChannelBuilderconcurrency in interface InboundChannelModelBuilder.InboundJmsChannelBuilderpublic InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder eventProcessingPipeline()
InboundChannelModelBuilder.InboundJmsChannelBuilderInboundChannelModel by configuring the next parts (if any).eventProcessingPipeline in interface InboundChannelModelBuilder.InboundJmsChannelBuilderCopyright © 2023 Flowable. All rights reserved.