X-Git-Url: https://juplo.de/gitweb/?p=demos%2Fkafka%2Foutbox;a=blobdiff_plain;f=delivery%2Fsrc%2Fmain%2Fjava%2Fde%2Fjuplo%2Fkafka%2Foutbox%2Fdelivery%2FOutboxProducer.java;h=79b3e029e304260ea1594559669b5ac188fb17cf;hp=c08cae7d6756655e5dbbe55dce19c2c3ed92256d;hb=e9fc9733c176964466d42643a2e36f7f4179df7b;hpb=fbd0ca0df5004d13a5e93cdb8373bafc60440c8b diff --git a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java b/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java index c08cae7..79b3e02 100644 --- a/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java +++ b/delivery/src/main/java/de/juplo/kafka/outbox/delivery/OutboxProducer.java @@ -44,7 +44,7 @@ public class OutboxProducer this.topic = properties.topic; } - @Scheduled(fixedDelay = 500) + @Scheduled(fixedDelayString = "${de.juplo.kafka.outbox.interval}") public void poll() { List items;