You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/03/22 10:20:39 UTC
[camel] 02/06: (chores) camel-consul: replace inner class with lambda
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 249317f9975187826ecd968470e4a765096802b1
Author: Gilvan Filho <gf...@redhat.com>
AuthorDate: Sat Mar 11 22:33:23 2023 -0300
(chores) camel-consul: replace inner class with lambda
---
.../camel/component/consul/endpoint/ConsulEventConsumer.java | 10 +++-------
1 file changed, 3 insertions(+), 7 deletions(-)
diff --git a/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulEventConsumer.java b/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulEventConsumer.java
index 25e6aaf7410..d28b64311be 100644
--- a/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulEventConsumer.java
+++ b/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulEventConsumer.java
@@ -78,13 +78,9 @@ public final class ConsulEventConsumer extends AbstractConsulConsumer<EventClien
@Override
public void watch(final EventClient client) {
- scheduledExecutorService.schedule(new Runnable() {
- @Override
- public void run() {
- client.listEvents(key, QueryOptions.blockSeconds(configuration.getBlockSeconds(), index.get()).build(),
- EventWatcher.this);
- }
- }, configuration.getBlockSeconds(), TimeUnit.SECONDS);
+ Runnable runnable = () -> client.listEvents(key,
+ QueryOptions.blockSeconds(configuration.getBlockSeconds(), index.get()).build(), EventWatcher.this);
+ scheduledExecutorService.schedule(runnable, configuration.getBlockSeconds(), TimeUnit.SECONDS);
}
@Override