camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [1/3] camel git commit: CAMEL-10128: camel-jt400 - Need to call configure consumer
Date Wed, 06 Jul 2016 10:41:06 GMT
Repository: camel
Updated Branches:
  refs/heads/camel-2.16.x 64f30474c -> 80629f001
  refs/heads/camel-2.17.x 8192f3bef -> 9e2f79c1d
  refs/heads/master 11469adce -> c2e0026c4


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/c2e0026c
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c2e0026c
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c2e0026c

Branch: refs/heads/master
Commit: c2e0026c4f4c58edf951c5c3d071ef39f1550fe4
Parents: 11469ad
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Wed Jul 6 12:40:03 2016 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Wed Jul 6 12:40:03 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/c2e0026c/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();
         }


Mime
View raw message