Package org.flowable.spring.boot.eventregistry

Class EventRegistryAutoConfiguration.EventRegistryKafkaConfiguration

java.lang.Object

org.flowable.spring.boot.eventregistry.EventRegistryAutoConfiguration.EventRegistryKafkaConfiguration

Enclosing class:

EventRegistryAutoConfiguration

@Configuration(proxyBeanMethods=false)
@ConditionalOnBean(org.springframework.kafka.core.KafkaOperations.class)
public static class EventRegistryAutoConfiguration.EventRegistryKafkaConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
EventRegistryKafkaConfiguration()

Method Summary

Modifier and Type	Method	Description
org.flowable.eventregistry.spring.kafka.KafkaChannelDefinitionProcessor	kafkaChannelDefinitionProcessor(org.springframework.kafka.config.KafkaListenerEndpointRegistry endpointRegistry, org.springframework.kafka.core.KafkaOperations<Object,Object> kafkaOperations, com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.listener.KafkaConsumerBackoffManager> kafkaConsumerBackoffManager, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.core.KafkaAdminOperations> kafkaAdminOperations)
EngineConfigurationConfigurer<org.flowable.eventregistry.spring.SpringEventRegistryEngineConfiguration>	kafkaEventRegistryEngineConfigurer()

Methods inherited from class java.lang.Object

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

Constructor Detail

EventRegistryKafkaConfiguration

public EventRegistryKafkaConfiguration()

Method Detail

kafkaChannelDefinitionProcessor

@Bean("kafkaChannelDefinitionProcessor")
@ConditionalOnMissingBean(name="kafkaChannelDefinitionProcessor")
public org.flowable.eventregistry.spring.kafka.KafkaChannelDefinitionProcessor kafkaChannelDefinitionProcessor(org.springframework.kafka.config.KafkaListenerEndpointRegistry endpointRegistry,
                                                                                                               org.springframework.kafka.core.KafkaOperations<Object,Object> kafkaOperations,
                                                                                                               com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                                                                                               org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.listener.KafkaConsumerBackoffManager> kafkaConsumerBackoffManager,
                                                                                                               org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.core.KafkaAdminOperations> kafkaAdminOperations)

kafkaEventRegistryEngineConfigurer

@Bean("kafkaEventRegistryEngineConfigurer")
@ConditionalOnMissingBean(name="kafkaEventRegistryEngineConfigurer")
public EngineConfigurationConfigurer<org.flowable.eventregistry.spring.SpringEventRegistryEngineConfiguration> kafkaEventRegistryEngineConfigurer()