projects
/
demos
/
kafka
/
outbox
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
| inline |
side by side
Made the polling-interval configurable
[demos/kafka/outbox]
/
delivery
/
src
/
main
/
java
/
de
/
juplo
/
kafka
/
outbox
/
delivery
/
OutboxProducer.java
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
(file)
--- 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(fixedDelay
String = "${de.juplo.kafka.outbox.interval}"
)
public void poll()
{
List<OutboxItem> items;