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();