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 <[email protected]> Authored: Wed Jul 6 12:40:03 2016 +0200 Committer: Claus Ibsen <[email protected]> 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(); }
