Package org.flowable.eventregistry.impl.model

Class OutboundChannelDefinitionBuilderImpl.OutboundKafkaChannelBuilderImpl

java.lang.Object

org.flowable.eventregistry.impl.model.OutboundChannelDefinitionBuilderImpl.OutboundKafkaChannelBuilderImpl

All Implemented Interfaces:

OutboundChannelModelBuilder.OutboundKafkaChannelBuilder

Enclosing class:

OutboundChannelDefinitionBuilderImpl

public static class OutboundChannelDefinitionBuilderImpl.OutboundKafkaChannelBuilderImpl
extends Object
implements OutboundChannelModelBuilder.OutboundKafkaChannelBuilder

Field Summary

Fields

Modifier and Type	Field	Description
protected final EventRepositoryService	eventRepositoryService
protected KafkaOutboundChannelModel	kafkaChannel
protected final OutboundChannelDefinitionBuilderImpl	outboundChannelDefinitionBuilder

Constructor Summary

Constructors

Constructor	Description
OutboundKafkaChannelBuilderImpl(EventRepositoryService eventRepositoryService, OutboundChannelDefinitionBuilderImpl outboundChannelDefinitionBuilder, KafkaOutboundChannelModel kafkaChannel)

Method Summary

Modifier and Type	Method	Description
OutboundChannelModelBuilder.OutboundEventProcessingPipelineBuilder	eventProcessingPipeline()
OutboundChannelModelBuilder.OutboundKafkaChannelBuilder	recordKey(String key)	Sets the record key for the outgoing message.

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

outboundChannelDefinitionBuilder

protected final OutboundChannelDefinitionBuilderImpl outboundChannelDefinitionBuilder

kafkaChannel

protected KafkaOutboundChannelModel kafkaChannel

Constructor Details

OutboundKafkaChannelBuilderImpl

public OutboundKafkaChannelBuilderImpl(EventRepositoryService eventRepositoryService,
 OutboundChannelDefinitionBuilderImpl outboundChannelDefinitionBuilder,
 KafkaOutboundChannelModel kafkaChannel)

Method Details

recordKey

public OutboundChannelModelBuilder.OutboundKafkaChannelBuilder recordKey(String key)

Description copied from interface: OutboundChannelModelBuilder.OutboundKafkaChannelBuilder

Sets the record key for the outgoing message.

Specified by:

recordKey in interface OutboundChannelModelBuilder.OutboundKafkaChannelBuilder

eventProcessingPipeline

public OutboundChannelModelBuilder.OutboundEventProcessingPipelineBuilder eventProcessingPipeline()

Specified by:

eventProcessingPipeline in interface OutboundChannelModelBuilder.OutboundKafkaChannelBuilder