Package su.onno.kafka

Class OnnoKafkaInboundAutoConfiguration

java.lang.Object

su.onno.kafka.OnnoKafkaInboundAutoConfiguration

@AutoConfiguration(after=org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration.class)
@ConditionalOnClass({org.springframework.kafka.core.KafkaTemplate.class,org.springframework.kafka.listener.ConcurrentMessageListenerContainer.class})
@ConditionalOnProperty(prefix="onno.kafka.inbound",
                       name="enabled",
                       havingValue="true")
@EnableConfigurationProperties(OnnoKafkaProperties.class)
public class OnnoKafkaInboundAutoConfiguration
extends Object

Constructor Summary

Constructors

Constructor	Description
OnnoKafkaInboundAutoConfiguration()

Method Summary

Modifier and Type	Method	Description
InboundEventRouter	inboundEventRouter(org.springframework.beans.factory.ObjectProvider<EventHandler> handlers)
KafkaEventConsumer	kafkaEventConsumer(InboundEventRouter router, com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.springframework.beans.factory.ObjectProvider<Inbox> inbox, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.core.KafkaTemplate<String,String>> kafkaTemplate, OnnoKafkaProperties properties)
org.springframework.kafka.listener.ConcurrentMessageListenerContainer<String,String>	onnoInboundContainer(org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties, KafkaEventConsumer consumer, OnnoKafkaProperties properties)
Inbox	onnoInbox(DataSource dataSource)

Methods inherited from class java.lang.Object

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

Constructor Details

OnnoKafkaInboundAutoConfiguration

public OnnoKafkaInboundAutoConfiguration()

Method Details

onnoInbox

@Bean
@ConditionalOnBean(javax.sql.DataSource.class)
@ConditionalOnMissingBean
public Inbox onnoInbox(DataSource dataSource)

inboundEventRouter

@Bean
@ConditionalOnMissingBean
public InboundEventRouter inboundEventRouter(org.springframework.beans.factory.ObjectProvider<EventHandler> handlers)

kafkaEventConsumer

@Bean
@ConditionalOnMissingBean
public KafkaEventConsumer kafkaEventConsumer(InboundEventRouter router,
 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
 org.springframework.beans.factory.ObjectProvider<Inbox> inbox,
 org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.core.KafkaTemplate<String,String>> kafkaTemplate,
 OnnoKafkaProperties properties)

onnoInboundContainer

@Bean
@ConditionalOnMissingBean(name="onnoInboundContainer")
public org.springframework.kafka.listener.ConcurrentMessageListenerContainer<String,String> onnoInboundContainer(org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties,
 KafkaEventConsumer consumer,
 OnnoKafkaProperties properties)