Package org.zalando.nakadiproducer

Class EventTransmissionScheduler

java.lang.Object

org.zalando.nakadiproducer.EventTransmissionScheduler

public class EventTransmissionScheduler
extends Object

Constructor Summary

Constructors

Constructor	Description
EventTransmissionScheduler(org.zalando.nakadiproducer.transmission.impl.EventTransmitter eventTransmitter, boolean scheduledTransmissionEnabled)

Method Summary

Modifier and Type	Method	Description
protected void	sendEventsIfSchedulingEnabled()

Methods inherited from class java.lang.Object

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

Constructor Detail

EventTransmissionScheduler

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

Method Detail

sendEventsIfSchedulingEnabled

@Scheduled(fixedDelayString="${nakadi-producer.transmission-polling-delay:1000}")
protected void sendEventsIfSchedulingEnabled()