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 2016/07/06 10:41:07 UTC
[2/3] camel git commit: CAMEL-10128: camel-jt400 - Need to call
configure consumer
CAMEL-10128: camel-jt400 - Need to call configure consumer
Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/9e2f79c1
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/9e2f79c1
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/9e2f79c1
Branch: refs/heads/camel-2.17.x
Commit: 9e2f79c1d1a7b0f4e7ee2af2f707579899e028b3
Parents: 8192f3b
Author: Claus Ibsen <da...@apache.org>
Authored: Wed Jul 6 12:40:03 2016 +0200
Committer: Claus Ibsen <da...@apache.org>
Committed: Wed Jul 6 12:40:36 2016 +0200
----------------------------------------------------------------------
.../java/org/apache/camel/component/jt400/Jt400Endpoint.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/camel/blob/9e2f79c1/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java b/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java
index bfc5ac7..7f6ae43 100644
--- a/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java
+++ b/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400Endpoint.java
@@ -88,7 +88,9 @@ public class Jt400Endpoint extends DefaultPollingEndpoint {
@Override
public Consumer createConsumer(Processor processor) throws Exception {
if (Jt400Type.DTAQ == configuration.getType()) {
- return new Jt400DataQueueConsumer(this);
+ Consumer consumer = new Jt400DataQueueConsumer(this);
+ configureConsumer(consumer);
+ return consumer;
} else {
throw new OperationNotSupportedException();
}