camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [2/2] camel git commit: CAMEL-10271: Fixed camel-jt400 consumer to be scheduled so it reads from the queue as the jt400 library is not event based.
Date Tue, 06 Sep 2016 10:13:28 GMT
CAMEL-10271: Fixed camel-jt400 consumer to be scheduled so it reads from the queue as the jt400
library is not event based.


Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/a5ae45e7
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/a5ae45e7
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/a5ae45e7

Branch: refs/heads/camel-2.17.x
Commit: a5ae45e7673f916961dd9464859266183822226e
Parents: b6424e7
Author: Claus Ibsen <davsclaus@apache.org>
Authored: Tue Sep 6 12:12:47 2016 +0200
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Tue Sep 6 12:13:18 2016 +0200

----------------------------------------------------------------------
 .../org/apache/camel/component/jt400/Jt400DataQueueConsumer.java   | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/a5ae45e7/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueConsumer.java
----------------------------------------------------------------------
diff --git a/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueConsumer.java
b/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueConsumer.java
index 6bf9788..e86008e 100644
--- a/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueConsumer.java
+++ b/components/camel-jt400/src/main/java/org/apache/camel/component/jt400/Jt400DataQueueConsumer.java
@@ -63,10 +63,12 @@ public class Jt400DataQueueConsumer extends ScheduledPollConsumer {
     @Override
     protected void doStart() throws Exception {
         queueService.start();
+        super.doStart();
     }
 
     @Override
     protected void doStop() throws Exception {
+        super.doStop();
         queueService.stop();
     }
 


Mime
View raw message