You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2021/05/05 15:11:37 UTC

[camel] 05/05: CAMEL-16394: Route Template local beans. WIP

This is an automated email from the ASF dual-hosted git repository.

davsclaus pushed a commit to branch kamelet-local-registry
in repository https://gitbox.apache.org/repos/asf/camel.git

commit ae6755d5b723853fd8ae9ba5399bd552b89fc9d9
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Wed May 5 17:10:32 2021 +0200

    CAMEL-16394: Route Template local beans. WIP
---
 .../org/apache/camel/component/consul/ConsulRegistry.java     | 11 +++++++++++
 1 file changed, 11 insertions(+)

diff --git a/components/camel-consul/src/main/java/org/apache/camel/component/consul/ConsulRegistry.java b/components/camel-consul/src/main/java/org/apache/camel/component/consul/ConsulRegistry.java
index 49b6276..5aae114 100644
--- a/components/camel-consul/src/main/java/org/apache/camel/component/consul/ConsulRegistry.java
+++ b/components/camel-consul/src/main/java/org/apache/camel/component/consul/ConsulRegistry.java
@@ -30,6 +30,7 @@ import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.UUID;
+import java.util.function.Supplier;
 
 import com.orbitz.consul.Consul;
 import com.orbitz.consul.ConsulException;
@@ -159,6 +160,16 @@ public class ConsulRegistry implements Registry {
         put(id, bean);
     }
 
+    @Override
+    public void bind(String id, Class<?> type, Supplier<Object> bean) throws RuntimeCamelException {
+        throw new UnsupportedOperationException("Binding with supplier not supported");
+    }
+
+    @Override
+    public void bindAsPrototype(String id, Class<?> type, Supplier<Object> bean) throws RuntimeCamelException {
+        throw new UnsupportedOperationException("Binding with supplier not supported");
+    }
+
     public void remove(String key) {
         // create session to avoid conflicts (not sure if that is safe enough)
         SessionClient sessionClient = consul.sessionClient();