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/02/06 12:05:02 UTC
[camel] 09/18: CAMEL-16102: Source code generate @InvokeOnHeader
for reflection free
This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch on-header
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 6c9a22e76cd386bb059acb8c058d79802fadba56
Author: Claus Ibsen <cl...@gmail.com>
AuthorDate: Thu Feb 4 17:06:33 2021 +0100
CAMEL-16102: Source code generate @InvokeOnHeader for reflection free
---
.../client/AbstractAtomixClientProducer.java | 2 -
...CaffeineCacheProducerInvokeOnHeaderFactory.java | 20 ++--
...eineLoadCacheProducerInvokeOnHeaderFactory.java | 12 +--
....component.caffeine.cache.CaffeineCacheProducer | 2 +-
...mponent.caffeine.load.CaffeineLoadCacheProducer | 2 +-
.../ConsulAgentProducerInvokeOnHeaderFactory.java | 32 ++++++
...ConsulCatalogProducerInvokeOnHeaderFactory.java | 16 +--
.../ConsulHealthProducerInvokeOnHeaderFactory.java | 8 +-
...onsulKeyValueProducerInvokeOnHeaderFactory.java | 24 ++---
...PreparedQueryProducerInvokeOnHeaderFactory.java | 4 +-
...ConsulSessionProducerInvokeOnHeaderFactory.java | 12 +--
.../ConsulStatusProducerInvokeOnHeaderFactory.java | 28 +++++
...l.component.consul.endpoint.ConsulAgentProducer | 2 +
...component.consul.endpoint.ConsulCatalogProducer | 2 +-
...onent.consul.endpoint.ConsulCoordinatesProducer | 2 +-
...l.component.consul.endpoint.ConsulEventProducer | 2 +-
....component.consul.endpoint.ConsulHealthProducer | 2 +-
...omponent.consul.endpoint.ConsulKeyValueProducer | 2 +-
...ent.consul.endpoint.ConsulPreparedQueryProducer | 2 +-
...component.consul.endpoint.ConsulSessionProducer | 2 +-
....component.consul.endpoint.ConsulStatusProducer | 2 +
.../consul/endpoint/ConsulAgentProducer.java | 26 ++++-
.../consul/endpoint/ConsulStatusProducer.java | 14 ++-
.../corda/CordaProducerInvokeOnHeaderFactory.java | 116 ++++++++++-----------
.../org.apache.camel.component.corda.CordaProducer | 2 +-
25 files changed, 214 insertions(+), 124 deletions(-)
diff --git a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/AbstractAtomixClientProducer.java b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/AbstractAtomixClientProducer.java
index c9ea246..c2d766a 100644
--- a/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/AbstractAtomixClientProducer.java
+++ b/components/camel-atomix/src/main/java/org/apache/camel/component/atomix/client/AbstractAtomixClientProducer.java
@@ -23,10 +23,8 @@ import java.util.concurrent.ConcurrentMap;
import io.atomix.resource.Resource;
import org.apache.camel.AsyncCallback;
-import org.apache.camel.Exchange;
import org.apache.camel.Message;
import org.apache.camel.component.atomix.AtomixAsyncMessageProcessor;
-import org.apache.camel.support.DefaultAsyncProducer;
import org.apache.camel.support.HeaderSelectorProducer;
import org.apache.camel.util.ObjectHelper;
import org.slf4j.Logger;
diff --git a/components/camel-caffeine/src/generated/java/org/apache/camel/component/caffeine/cache/CaffeineCacheProducerInvokeOnHeaderFactory.java b/components/camel-caffeine/src/generated/java/org/apache/camel/component/caffeine/cache/CaffeineCacheProducerInvokeOnHeaderFactory.java
index 000bb11..3503a5e 100644
--- a/components/camel-caffeine/src/generated/java/org/apache/camel/component/caffeine/cache/CaffeineCacheProducerInvokeOnHeaderFactory.java
+++ b/components/camel-caffeine/src/generated/java/org/apache/camel/component/caffeine/cache/CaffeineCacheProducerInvokeOnHeaderFactory.java
@@ -16,20 +16,20 @@ public class CaffeineCacheProducerInvokeOnHeaderFactory implements InvokeOnHeade
public Object invoke(Object obj, String key, Exchange exchange, AsyncCallback callback) throws Exception {
org.apache.camel.component.caffeine.cache.CaffeineCacheProducer target = (org.apache.camel.component.caffeine.cache.CaffeineCacheProducer) obj;
switch (key) {
- case "invalidate_all":
- case "INVALIDATE_ALL": target.onInvalidateAll(exchange.getMessage()); return null;
- case "put":
- case "PUT": target.onPut(exchange.getMessage()); return null;
+ case "invalidate":
+ case "INVALIDATE": target.onInvalidate(exchange.getMessage()); return null;
+ case "get_all":
+ case "GET_ALL": target.onGetAll(exchange.getMessage()); return null;
case "cleanup":
case "CLEANUP": target.onCleanUp(exchange.getMessage()); return null;
- case "get":
- case "GET": target.onGet(exchange.getMessage()); return null;
+ case "put":
+ case "PUT": target.onPut(exchange.getMessage()); return null;
case "put_all":
case "PUT_ALL": target.onPutAll(exchange.getMessage()); return null;
- case "get_all":
- case "GET_ALL": target.onGetAll(exchange.getMessage()); return null;
- case "invalidate":
- case "INVALIDATE": target.onInvalidate(exchange.getMessage()); return null;
+ case "get":
+ case "GET": target.onGet(exchange.getMessage()); return null;
+ case "invalidate_all":
+ case "INVALIDATE_ALL": target.onInvalidateAll(exchange.getMessage()); return null;
default: return null;
}
}
diff --git a/components/camel-caffeine/src/generated/java/org/apache/camel/component/caffeine/load/CaffeineLoadCacheProducerInvokeOnHeaderFactory.java b/components/camel-caffeine/src/generated/java/org/apache/camel/component/caffeine/load/CaffeineLoadCacheProducerInvokeOnHeaderFactory.java
index 88c8473..1bac041 100644
--- a/components/camel-caffeine/src/generated/java/org/apache/camel/component/caffeine/load/CaffeineLoadCacheProducerInvokeOnHeaderFactory.java
+++ b/components/camel-caffeine/src/generated/java/org/apache/camel/component/caffeine/load/CaffeineLoadCacheProducerInvokeOnHeaderFactory.java
@@ -18,16 +18,16 @@ public class CaffeineLoadCacheProducerInvokeOnHeaderFactory implements InvokeOnH
switch (key) {
case "get_all":
case "GET_ALL": target.onGetAll(exchange.getMessage()); return null;
- case "cleanup":
- case "CLEANUP": target.onCleanUp(exchange.getMessage()); return null;
+ case "get":
+ case "GET": target.onGet(exchange.getMessage()); return null;
case "put":
case "PUT": target.onPut(exchange.getMessage()); return null;
- case "invalidate_all":
- case "INVALIDATE_ALL": target.onInvalidateAll(exchange.getMessage()); return null;
case "put_all":
case "PUT_ALL": target.onPutAll(exchange.getMessage()); return null;
- case "get":
- case "GET": target.onGet(exchange.getMessage()); return null;
+ case "cleanup":
+ case "CLEANUP": target.onCleanUp(exchange.getMessage()); return null;
+ case "invalidate_all":
+ case "INVALIDATE_ALL": target.onInvalidateAll(exchange.getMessage()); return null;
case "invalidate":
case "INVALIDATE": target.onInvalidate(exchange.getMessage()); return null;
default: return null;
diff --git a/components/camel-caffeine/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.caffeine.cache.CaffeineCacheProducer b/components/camel-caffeine/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.caffeine.cache.CaffeineCacheProducer
index 30a4448..0b79096 100644
--- a/components/camel-caffeine/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.caffeine.cache.CaffeineCacheProducer
+++ b/components/camel-caffeine/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.caffeine.cache.CaffeineCacheProducer
@@ -1,2 +1,2 @@
# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.caffeine.cache.CaffeineCacheProducer.CaffeineCacheProducerInvokeOnHeaderFactory
+class=org.apache.camel.component.caffeine.cache.CaffeineCacheProducerInvokeOnHeaderFactory
diff --git a/components/camel-caffeine/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.caffeine.load.CaffeineLoadCacheProducer b/components/camel-caffeine/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.caffeine.load.CaffeineLoadCacheProducer
index 3cf2b9e..2e40d7c 100644
--- a/components/camel-caffeine/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.caffeine.load.CaffeineLoadCacheProducer
+++ b/components/camel-caffeine/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.caffeine.load.CaffeineLoadCacheProducer
@@ -1,2 +1,2 @@
# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.caffeine.load.CaffeineLoadCacheProducer.CaffeineLoadCacheProducerInvokeOnHeaderFactory
+class=org.apache.camel.component.caffeine.load.CaffeineLoadCacheProducerInvokeOnHeaderFactory
diff --git a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulAgentProducerInvokeOnHeaderFactory.java b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulAgentProducerInvokeOnHeaderFactory.java
new file mode 100644
index 0000000..51699b1
--- /dev/null
+++ b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulAgentProducerInvokeOnHeaderFactory.java
@@ -0,0 +1,32 @@
+/* Generated by camel build tools - do NOT edit this file! */
+package org.apache.camel.component.consul.endpoint;
+
+import org.apache.camel.AsyncCallback;
+import org.apache.camel.Exchange;
+import org.apache.camel.spi.InvokeOnHeaderStrategy;
+import org.apache.camel.component.consul.endpoint.ConsulAgentProducer;
+
+/**
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@SuppressWarnings("unchecked")
+public class ConsulAgentProducerInvokeOnHeaderFactory implements InvokeOnHeaderStrategy {
+
+ @Override
+ public Object invoke(Object obj, String key, Exchange exchange, AsyncCallback callback) throws Exception {
+ org.apache.camel.component.consul.endpoint.ConsulAgentProducer target = (org.apache.camel.component.consul.endpoint.ConsulAgentProducer) obj;
+ switch (key) {
+ case "agent":
+ case "AGENT": return target.invokeAgent(exchange.getMessage());
+ case "services":
+ case "SERVICES": return target.invokeServices(exchange.getMessage());
+ case "checks":
+ case "CHECKS": return target.invokeChecks(exchange.getMessage());
+ case "members":
+ case "MEMBERS": return target.invokeMembers(exchange.getMessage());
+ default: return null;
+ }
+ }
+
+}
+
diff --git a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulCatalogProducerInvokeOnHeaderFactory.java b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulCatalogProducerInvokeOnHeaderFactory.java
index d5821d2..dada91a 100644
--- a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulCatalogProducerInvokeOnHeaderFactory.java
+++ b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulCatalogProducerInvokeOnHeaderFactory.java
@@ -16,20 +16,20 @@ public class ConsulCatalogProducerInvokeOnHeaderFactory implements InvokeOnHeade
public Object invoke(Object obj, String key, Exchange exchange, AsyncCallback callback) throws Exception {
org.apache.camel.component.consul.endpoint.ConsulCatalogProducer target = (org.apache.camel.component.consul.endpoint.ConsulCatalogProducer) obj;
switch (key) {
+ case "deregister":
+ case "DEREGISTER": target.deregister(exchange.getMessage()); return null;
case "get_service":
case "GET_SERVICE": target.getService(exchange.getMessage()); return null;
- case "get_node":
- case "GET_NODE": target.getNode(exchange.getMessage()); return null;
- case "list_datacenters":
- case "LIST_DATACENTERS": target.listDatacenters(exchange.getMessage()); return null;
- case "list_nodes":
- case "LIST_NODES": target.listNodes(exchange.getMessage()); return null;
case "register":
case "REGISTER": target.register(exchange.getMessage()); return null;
- case "deregister":
- case "DEREGISTER": target.deregister(exchange.getMessage()); return null;
+ case "list_nodes":
+ case "LIST_NODES": target.listNodes(exchange.getMessage()); return null;
+ case "get_node":
+ case "GET_NODE": target.getNode(exchange.getMessage()); return null;
case "list_services":
case "LIST_SERVICES": target.listServices(exchange.getMessage()); return null;
+ case "list_datacenters":
+ case "LIST_DATACENTERS": target.listDatacenters(exchange.getMessage()); return null;
default: return null;
}
}
diff --git a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulHealthProducerInvokeOnHeaderFactory.java b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulHealthProducerInvokeOnHeaderFactory.java
index 8b65e37..fba734d 100644
--- a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulHealthProducerInvokeOnHeaderFactory.java
+++ b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulHealthProducerInvokeOnHeaderFactory.java
@@ -18,12 +18,12 @@ public class ConsulHealthProducerInvokeOnHeaderFactory implements InvokeOnHeader
switch (key) {
case "node_checks":
case "NODE_CHECKS": target.nodeChecks(exchange.getMessage()); return null;
- case "checks":
- case "CHECKS": target.checks(exchange.getMessage()); return null;
- case "service_checks":
- case "SERVICE_CHECKS": target.serviceChecks(exchange.getMessage()); return null;
case "service_instances":
case "SERVICE_INSTANCES": target.serviceInstances(exchange.getMessage()); return null;
+ case "service_checks":
+ case "SERVICE_CHECKS": target.serviceChecks(exchange.getMessage()); return null;
+ case "checks":
+ case "CHECKS": target.checks(exchange.getMessage()); return null;
default: return null;
}
}
diff --git a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulKeyValueProducerInvokeOnHeaderFactory.java b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulKeyValueProducerInvokeOnHeaderFactory.java
index 7f5a8dd..acc7c55 100644
--- a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulKeyValueProducerInvokeOnHeaderFactory.java
+++ b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulKeyValueProducerInvokeOnHeaderFactory.java
@@ -16,24 +16,24 @@ public class ConsulKeyValueProducerInvokeOnHeaderFactory implements InvokeOnHead
public Object invoke(Object obj, String key, Exchange exchange, AsyncCallback callback) throws Exception {
org.apache.camel.component.consul.endpoint.ConsulKeyValueProducer target = (org.apache.camel.component.consul.endpoint.ConsulKeyValueProducer) obj;
switch (key) {
- case "get_sessions":
- case "GET_SESSIONS": target.getSessions(exchange.getMessage()); return null;
- case "lock":
- case "LOCK": target.lock(exchange.getMessage()); return null;
- case "delete_key":
- case "DELETE_KEY": target.deleteKey(exchange.getMessage()); return null;
- case "get_value":
- case "GET_VALUE": target.getValue(exchange.getMessage()); return null;
- case "delete_keys":
- case "DELETE_KEYS": target.deleteKeys(exchange.getMessage()); return null;
case "get_values":
case "GET_VALUES": target.getValues(exchange.getMessage()); return null;
- case "put":
- case "PUT": target.put(exchange.getMessage()); return null;
case "get_keys":
case "GET_KEYS": target.getKeys(exchange.getMessage()); return null;
+ case "get_sessions":
+ case "GET_SESSIONS": target.getSessions(exchange.getMessage()); return null;
+ case "delete_keys":
+ case "DELETE_KEYS": target.deleteKeys(exchange.getMessage()); return null;
case "unlock":
case "UNLOCK": target.unlock(exchange.getMessage()); return null;
+ case "delete_key":
+ case "DELETE_KEY": target.deleteKey(exchange.getMessage()); return null;
+ case "put":
+ case "PUT": target.put(exchange.getMessage()); return null;
+ case "get_value":
+ case "GET_VALUE": target.getValue(exchange.getMessage()); return null;
+ case "lock":
+ case "LOCK": target.lock(exchange.getMessage()); return null;
default: return null;
}
}
diff --git a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulPreparedQueryProducerInvokeOnHeaderFactory.java b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulPreparedQueryProducerInvokeOnHeaderFactory.java
index cb374cb..31d2f67 100644
--- a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulPreparedQueryProducerInvokeOnHeaderFactory.java
+++ b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulPreparedQueryProducerInvokeOnHeaderFactory.java
@@ -16,10 +16,10 @@ public class ConsulPreparedQueryProducerInvokeOnHeaderFactory implements InvokeO
public Object invoke(Object obj, String key, Exchange exchange, AsyncCallback callback) throws Exception {
org.apache.camel.component.consul.endpoint.ConsulPreparedQueryProducer target = (org.apache.camel.component.consul.endpoint.ConsulPreparedQueryProducer) obj;
switch (key) {
- case "get":
- case "GET": target.get(exchange.getMessage()); return null;
case "execute":
case "EXECUTE": target.execute(exchange.getMessage()); return null;
+ case "get":
+ case "GET": target.get(exchange.getMessage()); return null;
case "create":
case "CREATE": target.create(exchange.getMessage()); return null;
default: return null;
diff --git a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulSessionProducerInvokeOnHeaderFactory.java b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulSessionProducerInvokeOnHeaderFactory.java
index 05617e0..bd67de1 100644
--- a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulSessionProducerInvokeOnHeaderFactory.java
+++ b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulSessionProducerInvokeOnHeaderFactory.java
@@ -16,16 +16,16 @@ public class ConsulSessionProducerInvokeOnHeaderFactory implements InvokeOnHeade
public Object invoke(Object obj, String key, Exchange exchange, AsyncCallback callback) throws Exception {
org.apache.camel.component.consul.endpoint.ConsulSessionProducer target = (org.apache.camel.component.consul.endpoint.ConsulSessionProducer) obj;
switch (key) {
- case "info":
- case "INFO": target.info(exchange.getMessage()); return null;
- case "create":
- case "CREATE": target.create(exchange.getMessage()); return null;
case "renew":
case "RENEW": target.renew(exchange.getMessage()); return null;
- case "list":
- case "LIST": target.list(exchange.getMessage()); return null;
case "destroy":
case "DESTROY": target.destroy(exchange.getMessage()); return null;
+ case "create":
+ case "CREATE": target.create(exchange.getMessage()); return null;
+ case "list":
+ case "LIST": target.list(exchange.getMessage()); return null;
+ case "info":
+ case "INFO": target.info(exchange.getMessage()); return null;
default: return null;
}
}
diff --git a/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulStatusProducerInvokeOnHeaderFactory.java b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulStatusProducerInvokeOnHeaderFactory.java
new file mode 100644
index 0000000..59e5f27
--- /dev/null
+++ b/components/camel-consul/src/generated/java/org/apache/camel/component/consul/endpoint/ConsulStatusProducerInvokeOnHeaderFactory.java
@@ -0,0 +1,28 @@
+/* Generated by camel build tools - do NOT edit this file! */
+package org.apache.camel.component.consul.endpoint;
+
+import org.apache.camel.AsyncCallback;
+import org.apache.camel.Exchange;
+import org.apache.camel.spi.InvokeOnHeaderStrategy;
+import org.apache.camel.component.consul.endpoint.ConsulStatusProducer;
+
+/**
+ * Generated by camel build tools - do NOT edit this file!
+ */
+@SuppressWarnings("unchecked")
+public class ConsulStatusProducerInvokeOnHeaderFactory implements InvokeOnHeaderStrategy {
+
+ @Override
+ public Object invoke(Object obj, String key, Exchange exchange, AsyncCallback callback) throws Exception {
+ org.apache.camel.component.consul.endpoint.ConsulStatusProducer target = (org.apache.camel.component.consul.endpoint.ConsulStatusProducer) obj;
+ switch (key) {
+ case "leader":
+ case "LEADER": return target.invokeChecks(exchange.getMessage());
+ case "peers":
+ case "PEERS": return target.invokePeers(exchange.getMessage());
+ default: return null;
+ }
+ }
+
+}
+
diff --git a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulAgentProducer b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulAgentProducer
new file mode 100644
index 0000000..712694b
--- /dev/null
+++ b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulAgentProducer
@@ -0,0 +1,2 @@
+# Generated by camel build tools - do NOT edit this file!
+class=org.apache.camel.component.consul.endpoint.ConsulAgentProducerInvokeOnHeaderFactory
diff --git a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulCatalogProducer b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulCatalogProducer
index 27ce6b7..2869dc1 100644
--- a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulCatalogProducer
+++ b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulCatalogProducer
@@ -1,2 +1,2 @@
# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.consul.endpoint.ConsulCatalogProducer.ConsulCatalogProducerInvokeOnHeaderFactory
+class=org.apache.camel.component.consul.endpoint.ConsulCatalogProducerInvokeOnHeaderFactory
diff --git a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulCoordinatesProducer b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulCoordinatesProducer
index d1906cb..6ead52c 100644
--- a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulCoordinatesProducer
+++ b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulCoordinatesProducer
@@ -1,2 +1,2 @@
# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.consul.endpoint.ConsulCoordinatesProducer.ConsulCoordinatesProducerInvokeOnHeaderFactory
+class=org.apache.camel.component.consul.endpoint.ConsulCoordinatesProducerInvokeOnHeaderFactory
diff --git a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulEventProducer b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulEventProducer
index a46e21e..b1d5fb3 100644
--- a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulEventProducer
+++ b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulEventProducer
@@ -1,2 +1,2 @@
# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.consul.endpoint.ConsulEventProducer.ConsulEventProducerInvokeOnHeaderFactory
+class=org.apache.camel.component.consul.endpoint.ConsulEventProducerInvokeOnHeaderFactory
diff --git a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulHealthProducer b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulHealthProducer
index ddd4593..5e0ff3d 100644
--- a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulHealthProducer
+++ b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulHealthProducer
@@ -1,2 +1,2 @@
# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.consul.endpoint.ConsulHealthProducer.ConsulHealthProducerInvokeOnHeaderFactory
+class=org.apache.camel.component.consul.endpoint.ConsulHealthProducerInvokeOnHeaderFactory
diff --git a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulKeyValueProducer b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulKeyValueProducer
index d1464a5..c1b996a 100644
--- a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulKeyValueProducer
+++ b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulKeyValueProducer
@@ -1,2 +1,2 @@
# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.consul.endpoint.ConsulKeyValueProducer.ConsulKeyValueProducerInvokeOnHeaderFactory
+class=org.apache.camel.component.consul.endpoint.ConsulKeyValueProducerInvokeOnHeaderFactory
diff --git a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulPreparedQueryProducer b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulPreparedQueryProducer
index be8e52b..01430e1 100644
--- a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulPreparedQueryProducer
+++ b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulPreparedQueryProducer
@@ -1,2 +1,2 @@
# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.consul.endpoint.ConsulPreparedQueryProducer.ConsulPreparedQueryProducerInvokeOnHeaderFactory
+class=org.apache.camel.component.consul.endpoint.ConsulPreparedQueryProducerInvokeOnHeaderFactory
diff --git a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulSessionProducer b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulSessionProducer
index ab8e68b..9c27499 100644
--- a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulSessionProducer
+++ b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulSessionProducer
@@ -1,2 +1,2 @@
# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.consul.endpoint.ConsulSessionProducer.ConsulSessionProducerInvokeOnHeaderFactory
+class=org.apache.camel.component.consul.endpoint.ConsulSessionProducerInvokeOnHeaderFactory
diff --git a/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulStatusProducer b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulStatusProducer
new file mode 100644
index 0000000..51170ed
--- /dev/null
+++ b/components/camel-consul/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.consul.endpoint.ConsulStatusProducer
@@ -0,0 +1,2 @@
+# Generated by camel build tools - do NOT edit this file!
+class=org.apache.camel.component.consul.endpoint.ConsulStatusProducerInvokeOnHeaderFactory
diff --git a/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulAgentProducer.java b/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulAgentProducer.java
index 1f00c79..57f72e7 100644
--- a/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulAgentProducer.java
+++ b/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulAgentProducer.java
@@ -18,17 +18,35 @@ package org.apache.camel.component.consul.endpoint;
import com.orbitz.consul.AgentClient;
import com.orbitz.consul.Consul;
+import org.apache.camel.Message;
import org.apache.camel.component.consul.ConsulConfiguration;
import org.apache.camel.component.consul.ConsulEndpoint;
+import org.apache.camel.spi.InvokeOnHeader;
public final class ConsulAgentProducer extends AbstractConsulProducer<AgentClient> {
public ConsulAgentProducer(ConsulEndpoint endpoint, ConsulConfiguration configuration) {
super(endpoint, configuration, Consul::agentClient);
+ }
+
+ @InvokeOnHeader("CHECKS")
+ public Object invokeChecks(Message message) throws Exception {
+ return getClient().getChecks();
+ }
+
+ @InvokeOnHeader("SERVICES")
+ public Object invokeServices(Message message) throws Exception {
+ return getClient().getServices();
+ }
+
+ @InvokeOnHeader("MEMBERS")
+ public Object invokeMembers(Message message) throws Exception {
+ return getClient().getMembers();
+ }
- bind(ConsulAgentActions.CHECKS, wrap(c -> c.getChecks()));
- bind(ConsulAgentActions.SERVICES, wrap(c -> c.getServices()));
- bind(ConsulAgentActions.MEMBERS, wrap(c -> c.getMembers()));
- bind(ConsulAgentActions.AGENT, wrap(c -> c.getAgent()));
+ @InvokeOnHeader("AGENT")
+ public Object invokeAgent(Message message) throws Exception {
+ return getClient().getAgent();
}
+
}
diff --git a/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulStatusProducer.java b/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulStatusProducer.java
index 59223d0..6e13f3a 100644
--- a/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulStatusProducer.java
+++ b/components/camel-consul/src/main/java/org/apache/camel/component/consul/endpoint/ConsulStatusProducer.java
@@ -18,15 +18,25 @@ package org.apache.camel.component.consul.endpoint;
import com.orbitz.consul.Consul;
import com.orbitz.consul.StatusClient;
+import org.apache.camel.Message;
import org.apache.camel.component.consul.ConsulConfiguration;
import org.apache.camel.component.consul.ConsulEndpoint;
+import org.apache.camel.spi.InvokeOnHeader;
public final class ConsulStatusProducer extends AbstractConsulProducer<StatusClient> {
public ConsulStatusProducer(ConsulEndpoint endpoint, ConsulConfiguration configuration) {
super(endpoint, configuration, Consul::statusClient);
+ }
+
+ @InvokeOnHeader("LEADER")
+ public Object invokeChecks(Message message) throws Exception {
+ return getClient().getLeader();
+ }
- bind(ConsulStatusActions.LEADER, wrap(c -> c.getLeader()));
- bind(ConsulStatusActions.PEERS, wrap(c -> c.getPeers()));
+ @InvokeOnHeader("PEERS")
+ public Object invokePeers(Message message) throws Exception {
+ return getClient().getPeers();
}
+
}
diff --git a/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaProducerInvokeOnHeaderFactory.java b/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaProducerInvokeOnHeaderFactory.java
index 57575e8..d6dbe89 100644
--- a/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaProducerInvokeOnHeaderFactory.java
+++ b/components/camel-corda/src/generated/java/org/apache/camel/component/corda/CordaProducerInvokeOnHeaderFactory.java
@@ -16,82 +16,82 @@ public class CordaProducerInvokeOnHeaderFactory implements InvokeOnHeaderStrateg
public Object invoke(Object obj, String key, Exchange exchange, AsyncCallback callback) throws Exception {
org.apache.camel.component.corda.CordaProducer target = (org.apache.camel.component.corda.CordaProducer) obj;
switch (key) {
- case "accept_newnetwork_parameters":
- case "ACCEPT_NEWNETWORK_PARAMETERS": target.acceptNewNetworkParameters(exchange.getMessage()); return null;
- case "network_map_snapshot":
- case "NETWORK_MAP_SNAPSHOT": target.networkMapSnapshot(exchange.getMessage()); return null;
- case "parties_from_key":
- case "PARTIES_FROM_KEY": target.partyFromKey(exchange.getMessage()); return null;
- case "get_protocol_version":
- case "GET_PROTOCOL_VERSION": target.getProtocolVersion(exchange.getMessage()); return null;
- case "parties_from_name":
- case "PARTIES_FROM_NAME": target.partiesFromName(exchange.getMessage()); return null;
+ case "kill_flow":
+ case "KILL_FLOW": target.killFlow(exchange.getMessage()); return null;
+ case "registered_flows":
+ case "REGISTERED_FLOWS": target.registeredFlows(exchange.getMessage()); return null;
+ case "query_attachments":
+ case "QUERY_ATTACHMENTS": target.queryAttachments(exchange.getMessage()); return null;
+ case "vault_query_by_with_paging_spec":
+ case "VAULT_QUERY_BY_WITH_PAGING_SPEC": target.vaultQueryByWithPagingSpec(exchange.getMessage()); return null;
case "node_info":
case "NODE_INFO": target.nodeInfo(exchange.getMessage()); return null;
- case "notary_party_from_x500_name":
- case "NOTARY_PARTY_FROM_X500_NAME": target.notaryPartyFromX500Name(exchange.getMessage()); return null;
- case "start_flow_dynamic":
- case "START_FLOW_DYNAMIC": target.startFlowDynamic(exchange.getMessage()); return null;
- case "terminate":
- case "TERMINATE": target.terminate(exchange.getMessage()); return null;
- case "attachment_exists":
- case "ATTACHMENT_EXISTS": target.attachmentExists(exchange.getMessage()); return null;
case "node_info_from_party":
case "NODE_INFO_FROM_PARTY": target.nodeInfoFromParty(exchange.getMessage()); return null;
- case "registered_flows":
- case "REGISTERED_FLOWS": target.registeredFlows(exchange.getMessage()); return null;
case "well_known_party_from_anonymous":
case "WELL_KNOWN_PARTY_FROM_ANONYMOUS": target.wellKnownPartyFromAnonymous(exchange.getMessage()); return null;
- case "vault_query":
- case "VAULT_QUERY": target.vaultQuery(exchange.getMessage()); return null;
- case "upload_attachment":
- case "UPLOAD_ATTACHMENT": target.uploadAttachment(exchange.getMessage()); return null;
+ case "network_parameters_feed":
+ case "NETWORK_PARAMETERS_FEED": target.networkParametersFeed(exchange.getMessage()); return null;
+ case "vault_query_by":
+ case "VAULT_QUERY_BY": target.vaultQueryBy(exchange.getMessage()); return null;
+ case "parties_from_name":
+ case "PARTIES_FROM_NAME": target.partiesFromName(exchange.getMessage()); return null;
+ case "accept_newnetwork_parameters":
+ case "ACCEPT_NEWNETWORK_PARAMETERS": target.acceptNewNetworkParameters(exchange.getMessage()); return null;
case "set_flows_draining_mode_enabled":
case "SET_FLOWS_DRAINING_MODE_ENABLED": target.setFlowsDrainingModeEnabled(exchange.getMessage()); return null;
- case "vault_query_by_criteria":
- case "VAULT_QUERY_BY_CRITERIA": target.vaultQueryByCriteria(exchange.getMessage()); return null;
- case "open_attachment":
- case "OPEN_ATTACHMENT": target.openAttachment(exchange.getMessage()); return null;
- case "state_machine_recorded_transaction_mapping_snapshot":
- case "STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_SNAPSHOT": target.stateMachineRecordedTransactionMappingSnapshot(exchange.getMessage()); return null;
- case "get_vault_transaction_notes":
- case "GET_VAULT_TRANSACTION_NOTES": target.getVaultTransactionNotes(exchange.getMessage()); return null;
- case "kill_flow":
- case "KILL_FLOW": target.killFlow(exchange.getMessage()); return null;
- case "clear_network_map_cache":
- case "CLEAR_NETWORK_MAP_CACHE": target.clearNetworkMapCache(exchange.getMessage()); return null;
case "is_flows_draining_mode_enabled":
case "IS_FLOWS_DRAINING_MODE_ENABLED": target.isFlowsDrainingModeEnabled(exchange.getMessage()); return null;
- case "add_vault_transaction_note":
- case "ADD_VAULT_TRANSACTION_NOTE": target.addVaultTransactionNote(exchange.getMessage()); return null;
- case "is_waiting_for_shutdown":
- case "IS_WAITING_FOR_SHUTDOWN": target.isWaitingForShutdown(exchange.getMessage()); return null;
- case "network_parameters_feed":
- case "NETWORK_PARAMETERS_FEED": target.networkParametersFeed(exchange.getMessage()); return null;
- case "refresh_network_map_cache":
- case "REFRESH_NETWORK_MAP_CACHE": target.refreshNetworkMapCache(exchange.getMessage()); return null;
case "state_machine_snapshot":
case "STATE_MACHINE_SNAPSHOT": target.stateMachinesSnapshot(exchange.getMessage()); return null;
- case "query_attachments":
- case "QUERY_ATTACHMENTS": target.queryAttachments(exchange.getMessage()); return null;
- case "vault_query_by":
- case "VAULT_QUERY_BY": target.vaultQueryBy(exchange.getMessage()); return null;
+ case "vault_query_by_criteria":
+ case "VAULT_QUERY_BY_CRITERIA": target.vaultQueryByCriteria(exchange.getMessage()); return null;
+ case "well_known_party_from_x500_name":
+ case "WELL_KNOWN_PARTY_FROM_X500_NAME": target.wellKnownPartyFromX500Name(exchange.getMessage()); return null;
case "wait_until_network_ready":
case "WAIT_UNTIL_NETWORK_READY": target.waitUntilNetworkReady(exchange.getMessage()); return null;
- case "shutdown":
- case "SHUTDOWN": target.shutdown(exchange.getMessage()); return null;
- case "upload_attachment_with_meta_data":
- case "UPLOAD_ATTACHMENT_WITH_META_DATA": target.uploadAttachmentWithMetadata(exchange.getMessage()); return null;
- case "vault_query_by_with_paging_spec":
- case "VAULT_QUERY_BY_WITH_PAGING_SPEC": target.vaultQueryByWithPagingSpec(exchange.getMessage()); return null;
case "vault_query_by_with_sorting":
case "VAULT_QUERY_BY_WITH_SORTING": target.vaultQueryByWithSorting(exchange.getMessage()); return null;
- case "current_node_time":
- case "CURRENT_NODE_TIME": target.currentNodeTime(exchange.getMessage()); return null;
- case "well_known_party_from_x500_name":
- case "WELL_KNOWN_PARTY_FROM_X500_NAME": target.wellKnownPartyFromX500Name(exchange.getMessage()); return null;
+ case "get_protocol_version":
+ case "GET_PROTOCOL_VERSION": target.getProtocolVersion(exchange.getMessage()); return null;
+ case "start_flow_dynamic":
+ case "START_FLOW_DYNAMIC": target.startFlowDynamic(exchange.getMessage()); return null;
+ case "state_machine_recorded_transaction_mapping_snapshot":
+ case "STATE_MACHINE_RECORDED_TRANSACTION_MAPPING_SNAPSHOT": target.stateMachineRecordedTransactionMappingSnapshot(exchange.getMessage()); return null;
+ case "upload_attachment_with_meta_data":
+ case "UPLOAD_ATTACHMENT_WITH_META_DATA": target.uploadAttachmentWithMetadata(exchange.getMessage()); return null;
+ case "clear_network_map_cache":
+ case "CLEAR_NETWORK_MAP_CACHE": target.clearNetworkMapCache(exchange.getMessage()); return null;
+ case "vault_query":
+ case "VAULT_QUERY": target.vaultQuery(exchange.getMessage()); return null;
case "notary_identities":
case "NOTARY_IDENTITIES": target.notaryIdentities(exchange.getMessage()); return null;
+ case "network_map_snapshot":
+ case "NETWORK_MAP_SNAPSHOT": target.networkMapSnapshot(exchange.getMessage()); return null;
+ case "current_node_time":
+ case "CURRENT_NODE_TIME": target.currentNodeTime(exchange.getMessage()); return null;
+ case "open_attachment":
+ case "OPEN_ATTACHMENT": target.openAttachment(exchange.getMessage()); return null;
+ case "shutdown":
+ case "SHUTDOWN": target.shutdown(exchange.getMessage()); return null;
+ case "notary_party_from_x500_name":
+ case "NOTARY_PARTY_FROM_X500_NAME": target.notaryPartyFromX500Name(exchange.getMessage()); return null;
+ case "parties_from_key":
+ case "PARTIES_FROM_KEY": target.partyFromKey(exchange.getMessage()); return null;
+ case "add_vault_transaction_note":
+ case "ADD_VAULT_TRANSACTION_NOTE": target.addVaultTransactionNote(exchange.getMessage()); return null;
+ case "get_vault_transaction_notes":
+ case "GET_VAULT_TRANSACTION_NOTES": target.getVaultTransactionNotes(exchange.getMessage()); return null;
+ case "attachment_exists":
+ case "ATTACHMENT_EXISTS": target.attachmentExists(exchange.getMessage()); return null;
+ case "refresh_network_map_cache":
+ case "REFRESH_NETWORK_MAP_CACHE": target.refreshNetworkMapCache(exchange.getMessage()); return null;
+ case "upload_attachment":
+ case "UPLOAD_ATTACHMENT": target.uploadAttachment(exchange.getMessage()); return null;
+ case "is_waiting_for_shutdown":
+ case "IS_WAITING_FOR_SHUTDOWN": target.isWaitingForShutdown(exchange.getMessage()); return null;
+ case "terminate":
+ case "TERMINATE": target.terminate(exchange.getMessage()); return null;
default: return null;
}
}
diff --git a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.corda.CordaProducer b/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.corda.CordaProducer
index 2197873..0284213 100644
--- a/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.corda.CordaProducer
+++ b/components/camel-corda/src/generated/resources/META-INF/services/org/apache/camel/invoke-on-header/org.apache.camel.component.corda.CordaProducer
@@ -1,2 +1,2 @@
# Generated by camel build tools - do NOT edit this file!
-class=org.apache.camel.component.corda.CordaProducer.CordaProducerInvokeOnHeaderFactory
+class=org.apache.camel.component.corda.CordaProducerInvokeOnHeaderFactory