Package com.onec.kafka

Class OnecKafkaInboundAutoConfiguration

java.lang.Object

com.onec.kafka.OnecKafkaInboundAutoConfiguration

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

Constructor Summary

Constructors

Constructor	Description
OnecKafkaInboundAutoConfiguration()

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, OnecKafkaProperties properties)
org.springframework.kafka.listener.ConcurrentMessageListenerContainer<String,String>	onecInboundContainer(org.springframework.boot.autoconfigure.kafka.KafkaProperties kafkaProperties, KafkaEventConsumer consumer, OnecKafkaProperties properties)
Inbox	onecInbox(DataSource dataSource)

Methods inherited from class java.lang.Object

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

Constructor Details

OnecKafkaInboundAutoConfiguration

public OnecKafkaInboundAutoConfiguration()

Method Details

onecInbox

@Bean
@ConditionalOnBean(javax.sql.DataSource.class)
@ConditionalOnMissingBean
public Inbox onecInbox(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,
 OnecKafkaProperties properties)

onecInboundContainer

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