Package org.flowable.eventregistry.impl.model

Class InboundChannelDefinitionBuilderImpl.InboundKafkaChannelBuilderImpl

java.lang.Object

org.flowable.eventregistry.impl.model.InboundChannelDefinitionBuilderImpl.InboundKafkaChannelBuilderImpl

All Implemented Interfaces:

InboundChannelModelBuilder.InboundKafkaChannelBuilder

Enclosing class:

InboundChannelDefinitionBuilderImpl

public static class InboundChannelDefinitionBuilderImpl.InboundKafkaChannelBuilderImpl
extends Object
implements InboundChannelModelBuilder.InboundKafkaChannelBuilder

Field Summary

Fields

Modifier and Type	Field	Description
protected final InboundChannelDefinitionBuilderImpl	channelDefinitionBuilder
protected final EventRepositoryService	eventRepositoryService
protected KafkaInboundChannelModel	kafkaChannel

Constructor Summary

Constructors

Constructor	Description
InboundKafkaChannelBuilderImpl(KafkaInboundChannelModel kafkaChannel, EventRepositoryService eventRepositoryService, InboundChannelDefinitionBuilderImpl channelDefinitionBuilder)

Method Summary

Modifier and Type	Method	Description
InboundChannelModelBuilder.InboundKafkaChannelBuilder	clientIdPrefix(String clientIdPrefix)	Sets the client id prefix for this Kafka adapter.
InboundChannelModelBuilder.InboundKafkaChannelBuilder	concurrency(String concurrency)	Sets the concurrency (and integer) for this Kafka adapter.
InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder	eventProcessingPipeline()	Continue building the InboundChannelModel by configuring the next parts (if any).
InboundChannelModelBuilder.InboundKafkaChannelBuilder	groupId(String groupId)	Sets the groupId for this Kafka adapter.
InboundChannelModelBuilder.InboundKafkaChannelBuilder	property(String name, String value)	Sets custom properties for this Kafka adapter.

Methods inherited from class java.lang.Object

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

Field Details

eventRepositoryService

protected final EventRepositoryService eventRepositoryService

channelDefinitionBuilder

protected final InboundChannelDefinitionBuilderImpl channelDefinitionBuilder

kafkaChannel

protected KafkaInboundChannelModel kafkaChannel

Constructor Details

InboundKafkaChannelBuilderImpl

public InboundKafkaChannelBuilderImpl(KafkaInboundChannelModel kafkaChannel,
 EventRepositoryService eventRepositoryService,
 InboundChannelDefinitionBuilderImpl channelDefinitionBuilder)

Method Details

groupId

public InboundChannelModelBuilder.InboundKafkaChannelBuilder groupId(String groupId)

Description copied from interface: InboundChannelModelBuilder.InboundKafkaChannelBuilder

Sets the groupId for this Kafka adapter. See Kafka docs for more info.

Specified by:

groupId in interface InboundChannelModelBuilder.InboundKafkaChannelBuilder

clientIdPrefix

public InboundChannelModelBuilder.InboundKafkaChannelBuilder clientIdPrefix(String clientIdPrefix)

Description copied from interface: InboundChannelModelBuilder.InboundKafkaChannelBuilder

Sets the client id prefix for this Kafka adapter. See Kafka docs for more info.

Specified by:

clientIdPrefix in interface InboundChannelModelBuilder.InboundKafkaChannelBuilder

concurrency

public InboundChannelModelBuilder.InboundKafkaChannelBuilder concurrency(String concurrency)

Description copied from interface: InboundChannelModelBuilder.InboundKafkaChannelBuilder

Sets the concurrency (and integer) for this Kafka adapter. See the Spring Kafka docs for more information.

Specified by:

concurrency in interface InboundChannelModelBuilder.InboundKafkaChannelBuilder

property

public InboundChannelModelBuilder.InboundKafkaChannelBuilder property(String name,
 String value)

Description copied from interface: InboundChannelModelBuilder.InboundKafkaChannelBuilder

Sets custom properties for this Kafka adapter. See the Spring Kafka docs for more information.

Specified by:

property in interface InboundChannelModelBuilder.InboundKafkaChannelBuilder

eventProcessingPipeline

public InboundChannelModelBuilder.InboundEventProcessingPipelineBuilder eventProcessingPipeline()

Description copied from interface: InboundChannelModelBuilder.InboundKafkaChannelBuilder

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

Specified by:

eventProcessingPipeline in interface InboundChannelModelBuilder.InboundKafkaChannelBuilder