#34 - fixing lost scheduling

zalando-nakadi · May 23, 2017 · fda37a2 · fda37a2
1 parent d513e28
commit fda37a2
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/...oot-starter/src/main/java/org/zalando/nakadiproducer/NakadiProducerAutoConfiguration.java b/...oot-starter/src/main/java/org/zalando/nakadiproducer/NakadiProducerAutoConfiguration.java
@@ -29,6 +29,7 @@
 import org.springframework.context.annotation.Configuration;
 import org.springframework.context.annotation.Import;
 import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
+import org.springframework.scheduling.annotation.Scheduled;
 import org.zalando.fahrschein.NakadiClient;
 import org.zalando.nakadiproducer.eventlog.EventLogWriter;
 import org.zalando.nakadiproducer.eventlog.impl.EventLogRepository;
@@ -167,6 +168,11 @@ public EventTransmissionService eventTransmissionService(EventLogRepository even
         return new EventTransmissionService(eventLogRepository, nakadiPublishingClient, objectMapper);
     }
 
+    @Scheduled(fixedDelayString = "${nakadi-producer.transmission-polling-delay:1000}")
+    protected void sendEventsIfSchedulingEnabled(EventTransmitter eventTransmitter) {
+        eventTransmitter.sendEvents();
+    }
+
     @PostConstruct
     public void migrateFlyway() {
         Flyway flyway = new Flyway();