Package org.zalando.nakadiproducer

Class NakadiProducerAutoConfiguration

  • @Configuration
@AutoConfigureAfter(name="org.zalando.tracer.spring.TracerAutoConfiguration")
@EnableScheduling
@EnableConfigurationProperties({org.springframework.boot.autoconfigure.jdbc.DataSourceProperties.class,org.springframework.boot.autoconfigure.flyway.FlywayProperties.class})
public class NakadiProducerAutoConfiguration
extends Object

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.zalando.nakadiproducer.eventlog.impl.EventLogRepository eventLogRepository​(org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate namedParameterJdbcTemplate)  
      org.zalando.nakadiproducer.eventlog.EventLogWriter eventLogWriter​(org.zalando.nakadiproducer.eventlog.impl.EventLogRepository eventLogRepository, com.fasterxml.jackson.databind.ObjectMapper objectMapper, org.zalando.nakadiproducer.flowid.FlowIdComponent flowIdComponent)  
      EventTransmissionScheduler eventTransmissionScheduler​(org.zalando.nakadiproducer.transmission.impl.EventTransmitter eventTransmitter, boolean scheduledTransmissionEnabled)  
      org.zalando.nakadiproducer.transmission.impl.EventTransmissionService eventTransmissionService​(org.zalando.nakadiproducer.eventlog.impl.EventLogRepository eventLogRepository, org.zalando.nakadiproducer.transmission.NakadiPublishingClient nakadiPublishingClient, com.fasterxml.jackson.databind.ObjectMapper objectMapper, int lockDuration, int lockDurationBuffer)  
      org.zalando.nakadiproducer.transmission.impl.EventTransmitter eventTransmitter​(org.zalando.nakadiproducer.transmission.impl.EventTransmissionService eventTransmissionService)  
      org.zalando.nakadiproducer.flowid.FlowIdComponent flowIdComponent()  
      FlywayMigrator flywayMigrator()  
      org.zalando.nakadiproducer.snapshots.impl.SnapshotCreationService snapshotCreationService​(Optional<List<org.zalando.nakadiproducer.snapshots.SnapshotEventGenerator>> snapshotEventGenerators, org.zalando.nakadiproducer.eventlog.EventLogWriter eventLogWriter)  
      SnapshotEventCreationEndpoint snapshotEventCreationEndpoint​(org.zalando.nakadiproducer.snapshots.impl.SnapshotCreationService snapshotCreationService, org.zalando.nakadiproducer.flowid.FlowIdComponent flowIdComponent)  

    • Constructor Detail

      • NakadiProducerAutoConfiguration

        public NakadiProducerAutoConfiguration()

    • Method Detail

      • flowIdComponent

        @Bean
@ConditionalOnMissingClass("org.zalando.tracer.Tracer")
@ConditionalOnMissingBean(org.zalando.nakadiproducer.flowid.FlowIdComponent.class)
public org.zalando.nakadiproducer.flowid.FlowIdComponent flowIdComponent()

      • snapshotEventCreationEndpoint

        @Bean
@ConditionalOnMissingBean
public SnapshotEventCreationEndpoint snapshotEventCreationEndpoint​(org.zalando.nakadiproducer.snapshots.impl.SnapshotCreationService snapshotCreationService,
                                                                   org.zalando.nakadiproducer.flowid.FlowIdComponent flowIdComponent)

      • snapshotCreationService

        @Bean
public org.zalando.nakadiproducer.snapshots.impl.SnapshotCreationService snapshotCreationService​(Optional<List<org.zalando.nakadiproducer.snapshots.SnapshotEventGenerator>> snapshotEventGenerators,
                                                                                                 org.zalando.nakadiproducer.eventlog.EventLogWriter eventLogWriter)

      • eventLogWriter

        @Bean
public org.zalando.nakadiproducer.eventlog.EventLogWriter eventLogWriter​(org.zalando.nakadiproducer.eventlog.impl.EventLogRepository eventLogRepository,
                                                                         com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                                                         org.zalando.nakadiproducer.flowid.FlowIdComponent flowIdComponent)

      • eventLogRepository

        @Bean
public org.zalando.nakadiproducer.eventlog.impl.EventLogRepository eventLogRepository​(org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate namedParameterJdbcTemplate)

      • eventTransmitter

        @Bean
public org.zalando.nakadiproducer.transmission.impl.EventTransmitter eventTransmitter​(org.zalando.nakadiproducer.transmission.impl.EventTransmissionService eventTransmissionService)

      • eventTransmissionScheduler

        @Bean
public EventTransmissionScheduler eventTransmissionScheduler​(org.zalando.nakadiproducer.transmission.impl.EventTransmitter eventTransmitter,
                                                             @Value("${nakadi-producer.scheduled-transmission-enabled:true}")
                                                             boolean scheduledTransmissionEnabled)

      • eventTransmissionService

        @Bean
public org.zalando.nakadiproducer.transmission.impl.EventTransmissionService eventTransmissionService​(org.zalando.nakadiproducer.eventlog.impl.EventLogRepository eventLogRepository,
                                                                                                      org.zalando.nakadiproducer.transmission.NakadiPublishingClient nakadiPublishingClient,
                                                                                                      com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                                                                                      @Value("${nakadi-producer.lock-duration:600}")
                                                                                                      int lockDuration,
                                                                                                      @Value("${nakadi-producer.lock-duration-buffer:60}")
                                                                                                      int lockDurationBuffer)