[
https://issues.apache.org/jira/browse/CAMEL-10271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15464714#comment-15464714
]
Michael Watson commented on CAMEL-10271:
----------------------------------------
Have re-tested this and no longer get the exception on startup.
It appears to connect to the queue, but does not appear to actually be calling
the JT400DataQueueConsumer->receive method any longer (and indeed will not let
me add the consumer.delay property). How does the
JT400DataQueueConsumer->receive get called by Camel to receive entries that
appear on the queue? I cant see anything in the trace about the receive being
called, and have tested it by connecting it to both existing and non-existing
queue's, and adding entries to existing queues. No exceptions are thrown about
the non-existing queues and no entries are picked up from the existing queues.
2016-09-05 11:37:16.328 DEBUG 9436 --- [main]
c.m.c.f.launcher.CamelJobLauncherConfig : Building route for Legacy Job Queue
Trigger
2016-09-05 11:37:16.334 DEBUG 9436 --- [main]
c.m.c.f.launcher.CamelJobLauncherConfig : Using source queue
jt400://CMP070:[email protected]/QSYS.LIB/%LIBL%.LIB/BCH_LAUNCH.DTAQ
2016-09-05 11:37:16.336 DEBUG 9436 --- [main]
o.a.camel.spring.SpringCamelContext : Adding routes from builder: Routes:
[]
2016-09-05 11:37:16.440 DEBUG 9436 --- [main]
org.apache.camel.model.RouteDefinition : Tracing is enabled on route:
CamelJobQueueProcessor
2016-09-05 11:37:16.441 DEBUG 9436 --- [main]
org.apache.camel.model.RouteDefinition : Using AutoStartup true on route:
CamelJobQueueProcessor
2016-09-05 11:37:16.447 DEBUG 9436 --- [main]
o.a.camel.spring.SpringCamelContext : Using ComponentResolver:
org.apache.camel.impl.DefaultComponentResolver@7d75dce0 to resolve component
with name: jt400
2016-09-05 11:37:16.448 DEBUG 9436 --- [main]
o.a.camel.impl.DefaultComponentResolver : Found component: jt400 in registry:
null
2016-09-05 11:37:16.451 DEBUG 9436 --- [main]
o.a.camel.impl.DefaultComponentResolver : Found component: jt400 via type:
org.apache.camel.component.jt400.Jt400Component via:
META-INF/services/org/apache/camel/component/jt400
2016-09-05 11:37:16.476 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=components,name="jt400"
2016-09-05 11:37:16.476 DEBUG 9436 --- [main]
org.apache.camel.impl.DefaultComponent : Creating endpoint
uri=[jt400://CMP070:[email protected]/QSYS.LIB/%25LIBL%25.LIB/BCH_LAUNCH.DTAQ],
path=[CMP070:[email protected]/QSYS.LIB/%LIBL%.LIB/BCH_LAUNCH.DTAQ]
2016-09-05 11:37:16.477 TRACE 9436 --- [main]
o.a.c.component.jt400.Jt400Component : No AS400ConnectionPool instance
specified in the URI - one will be provided.
2016-09-05 11:37:16.481 INFO 9436 --- [main]
o.a.c.component.jt400.Jt400Component : Instantiating the default connection
pool ...
2016-09-05 11:37:16.504 DEBUG 9436 --- [main]
o.a.camel.spring.SpringCamelContext :
jt400://CMP070:[email protected]/QSYS.LIB/%25LIBL%25.LIB/BCH_LAUNCH.DTAQ
converted to endpoint:
Endpoint[jt400://CMP070:[email protected]/QSYS.LIB/%25LIBL%25.LIB/BCH_LAUNCH.DTAQ]
by component: org.apache.camel.component.jt400.Jt400Component@5b42abe3
2016-09-05 11:37:16.519 DEBUG 9436 --- [main]
o.a.c.p.interceptor.DefaultChannel : Initialize channel for target:
'process[Processor@0x4dab553a]'
2016-09-05 11:37:16.528 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=tracer,name=BacklogTracer
2016-09-05 11:37:16.538 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=tracer,name=BacklogDebugger
2016-09-05 11:37:16.574 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=errorhandlers,name="DefaultErrorHandlerBuilder(ref:CamelDefaultErrorHandlerBuilder)"
2016-09-05 11:37:16.582 DEBUG 9436 --- [main]
o.a.camel.spring.SpringCamelContext : Using ComponentResolver:
org.apache.camel.impl.DefaultComponentResolver@7d75dce0 to resolve component
with name: hazelcast
2016-09-05 11:37:16.584 DEBUG 9436 --- [main]
o.a.camel.impl.DefaultComponentResolver : Found component: hazelcast in
registry: null
2016-09-05 11:37:16.592 DEBUG 9436 --- [main]
o.a.camel.impl.DefaultComponentResolver : Found component: hazelcast via type:
org.apache.camel.component.hazelcast.HazelcastComponent via:
META-INF/services/org/apache/camel/component/hazelcast
2016-09-05 11:37:16.629 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=components,name="hazelcast"
2016-09-05 11:37:16.630 DEBUG 9436 --- [main]
org.apache.camel.impl.DefaultComponent : Creating endpoint
uri=[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap],
path=[map:jobNotificationQueue]
2016-09-05 11:37:16.633 DEBUG 9436 --- [main]
o.a.camel.util.IntrospectionSupport : Configured property:
hazelcastInstanceName on bean:
Endpoint[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap]
with value: cmpbatchserver-1.0-bootstrap
2016-09-05 11:37:16.635 DEBUG 9436 --- [main]
o.a.camel.spring.SpringCamelContext :
hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap
converted to endpoint:
Endpoint[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap]
by component: org.apache.camel.component.hazelcast.HazelcastComponent@2afe8a31
2016-09-05 11:37:16.644 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=endpoints,name="hazelcast://map:jobNotificationQueue\?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap"
2016-09-05 11:37:16.648 DEBUG 9436 --- [main]
o.a.c.p.interceptor.DefaultChannel : Initialize channel for target:
'To[hazelcast:map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap]'
2016-09-05 11:37:16.651 DEBUG 9436 --- [main]
o.a.c.p.interceptor.DefaultChannel : Initialize channel for target:
'SetHeader[CamelHazelcastOperationType, {31}]'
2016-09-05 11:37:16.667 DEBUG 9436 --- [main]
o.a.camel.spring.SpringCamelContext : Warming up route id:
CamelJobQueueProcessor having autoStartup=true
2016-09-05 11:37:16.667 DEBUG 9436 --- [main]
org.apache.camel.impl.RouteService : Starting services on route:
CamelJobQueueProcessor
2016-09-05 11:37:16.677 DEBUG 9436 --- [main]
org.apache.camel.impl.RouteService : Starting child service on route:
CamelJobQueueProcessor ->
Pipeline[[Channel[DelegateSync[com.mdscem.cmp.framework.launcher.CamelLegacyJobQueueProcessor@4dab553a]],
Channel[sendTo(Endpoint[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap])],
Channel[SetHeader(CamelHazelcastOperationType, 31)]]]
2016-09-05 11:37:16.687 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=producers,name=HazelcastMapProducer(0x72c73ac3)
2016-09-05 11:37:16.687 DEBUG 9436 --- [main]
o.a.c.c.h.map.HazelcastMapProducer : Starting producer:
Producer[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap]
2016-09-05 11:37:16.690 DEBUG 9436 --- [main]
org.apache.camel.impl.ProducerCache : Adding to producer cache with key:
Endpoint[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap]
for producer:
Producer[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap]
2016-09-05 11:37:16.694 DEBUG 9436 --- [main]
org.apache.camel.impl.RouteService : Starting child service on route:
CamelJobQueueProcessor ->
Pipeline[[Channel[DelegateSync[com.mdscem.cmp.framework.launcher.CamelLegacyJobQueueProcessor@4dab553a]],
Channel[sendTo(Endpoint[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap])],
Channel[SetHeader(CamelHazelcastOperationType, 31)]]]
2016-09-05 11:37:16.695 DEBUG 9436 --- [main]
org.apache.camel.impl.RouteService : Starting child service on route:
CamelJobQueueProcessor ->
DelegateSync[com.mdscem.cmp.framework.launcher.CamelLegacyJobQueueProcessor@4dab553a]
2016-09-05 11:37:16.761 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=processors,name="process1"
2016-09-05 11:37:16.761 DEBUG 9436 --- [main]
org.apache.camel.impl.RouteService : Starting child service on route:
CamelJobQueueProcessor ->
Channel[DelegateSync[com.mdscem.cmp.framework.launcher.CamelLegacyJobQueueProcessor@4dab553a]]
2016-09-05 11:37:16.762 DEBUG 9436 --- [main]
org.apache.camel.impl.RouteService : Starting child service on route:
CamelJobQueueProcessor ->
sendTo(Endpoint[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap])
2016-09-05 11:37:16.772 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=processors,name="to1"
2016-09-05 11:37:16.772 DEBUG 9436 --- [main]
org.apache.camel.impl.RouteService : Starting child service on route:
CamelJobQueueProcessor ->
Channel[sendTo(Endpoint[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap])]
2016-09-05 11:37:16.773 DEBUG 9436 --- [main]
org.apache.camel.impl.RouteService : Starting child service on route:
CamelJobQueueProcessor -> SetHeader(CamelHazelcastOperationType, 31)
2016-09-05 11:37:16.779 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=processors,name="setHeader1"
2016-09-05 11:37:16.779 DEBUG 9436 --- [main]
org.apache.camel.impl.RouteService : Starting child service on route:
CamelJobQueueProcessor -> Channel[SetHeader(CamelHazelcastOperationType, 31)]
2016-09-05 11:37:16.788 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=routes,name="CamelJobQueueProcessor"
2016-09-05 11:37:16.789 DEBUG 9436 --- [main]
o.a.camel.support.TimerListenerManager : Added TimerListener:
org.apache.camel.management.mbean.ManagedRoute@38781df9
2016-09-05 11:37:16.789 DEBUG 9436 --- [main]
o.a.camel.spring.SpringCamelContext : Route: CamelJobQueueProcessor >>>
EventDrivenConsumerRoute[Endpoint[jt400://CMP070:[email protected]/QSYS.LIB/%25LIBL%25.LIB/BCH_LAUNCH.DTAQ]
->
Pipeline[[Channel[DelegateSync[com.mdscem.cmp.framework.launcher.CamelLegacyJobQueueProcessor@4dab553a]],
Channel[sendTo(Endpoint[hazelcast://map:jobNotificationQueue?hazelcastInstanceName=cmpbatchserver-1.0-bootstrap])],
Channel[SetHeader(CamelHazelcastOperationType, 31)]]]]
2016-09-05 11:37:16.790 DEBUG 9436 --- [main]
o.a.camel.spring.SpringCamelContext : Starting consumer (order: 1000) on
route: CamelJobQueueProcessor
2016-09-05 11:37:16.797 DEBUG 9436 --- [main]
o.a.c.management.DefaultManagementAgent : Registered MBean with ObjectName:
org.apache.camel:context=camel-1,type=consumers,name=Jt400DataQueueConsumer(0x14f6940b)
2016-09-05 11:37:16.798 DEBUG 9436 --- [main] o.a.c.c.jt400.Jt400Configuration
: Getting an AS400 object for 'arch1.mdsuk.com/CMP070' from
com.ibm.as400.access.AS400ConnectionPool@38e4838b.
2016-09-05 11:37:16.824 INFO 9436 --- [main]
o.a.c.c.jt400.Jt400DataQueueService : Connecting to
Endpoint[jt400://CMP070:[email protected]/QSYS.LIB/%25LIBL%25.LIB/BCH_LAUNCH.DTAQ]
2016-09-05 11:37:16.845 INFO 9436 --- [main]
o.a.camel.spring.SpringCamelContext : Route: CamelJobQueueProcessor
started and consuming from:
Endpoint[jt400://CMP070:[email protected]/QSYS.LIB/%25LIBL%25.LIB/BCH_LAUNCH.DTAQ]
2016-09-05 11:37:16.846 INFO 9436 --- [main]
o.a.camel.spring.SpringCamelContext : Apache Camel 2.17.4-SNAPSHOT
(CamelContext: camel-1) is starting
2016-09-05 11:37:16.846 INFO 9436 --- [main]
o.a.camel.spring.SpringCamelContext : Total 1 routes, of which 1 are
started.
2016-09-05 11:37:16.847 INFO 9436 --- [main]
o.a.camel.spring.SpringCamelContext : Apache Camel 2.17.4-SNAPSHOT
(CamelContext: camel-1) started in 0.000 seconds
> camel-jt400 - Failed to resolve endpoint
> ----------------------------------------
>
> Key: CAMEL-10271
> URL: https://issues.apache.org/jira/browse/CAMEL-10271
> Project: Camel
> Issue Type: Bug
> Components: camel-jt400
> Affects Versions: 2.17.3
> Reporter: Michael Watson
> Assignee: Claus Ibsen
> Fix For: 2.18.0, 2.17.4
>
>
> Apologies for creating this in core, as there does not seem to be an entry
> for camel-jt400 (but the jar is distributed with 2.17.3)
> Creating a data queue end point using JT400 as per the documentation crashes
> out when the endpoint creation starts. This seems identical to the SNMP issue
> CAMEL-8479 (as it produces identical output other than the component name).
> Ideally the JT400Endpoint would be updated to return true for isLenient, or
> the default properties would be cleared prior to
> DefaultEndpoint.createEndpoint being called. Have not been able to find how
> the original SNMP issue was corrected and have been unable to find a
> workaround for it.
> Caused by: org.apache.camel.ResolveEndpointFailedException: Failed to resolve
> endpoint:
> jt400://XXXX:[email protected]/QSYS.LIB/AAAAAAAA.LIB/SENDJOB.DTAQ?consumer.initialDelay=2000&format=binary
> due to: There are 15 parameters that couldn't be set on the endpoint
> consumer. Check the uri if the parameters are spelt correctly and that they
> are properties of the endpoint. Unknown consumer
> parameters=[{backoffMultiplier=0, sendEmptyMessageWhenIdle=false,
> schedulerProperties=null, initialDelay=2000, backoffIdleThreshold=0,
> scheduler=null, delay=500, useFixedDelay=true,
> pollStrategy=org.apache.camel.impl.DefaultPollingConsumerPollStrategy@2172f79b,
> startScheduler=true, runLoggingLevel=TRACE, backoffErrorThreshold=0,
> greedy=false, scheduledExecutorService=null, timeUnit=MILLISECONDS}]
> at
> org.apache.camel.impl.DefaultEndpoint.configureConsumer(DefaultEndpoint.java:510)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.component.jt400.Jt400Endpoint.createConsumer(Jt400Endpoint.java:92)
> ~[camel-jt400-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.EventDrivenConsumerRoute.addServices(EventDrivenConsumerRoute.java:69)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultRoute.onStartingServices(DefaultRoute.java:103)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at org.apache.camel.impl.RouteService.warmUp(RouteService.java:158)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:3496)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3426)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:3203)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:3059)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:175)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2854)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2850)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2873)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:2850)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2819)
> ~[camel-core-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:270)
> ~[camel-spring-2.17.3.jar!/:2.17.3]
> at
> org.apache.camel.spring.SpringCamelContext.afterPropertiesSet(SpringCamelContext.java:122)
> ~[camel-spring-2.17.3.jar!/:2.17.3]
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.invokeInitMethods(AbstractAutowireCapableBeanFactory.java:1637)
> ~[spring-beans-4.3.0.RELEASE.jar!/:4.3.0.RELEASE]
> at
> org.springframework.beans.factory.support.AbstractAutowireCapableBeanFactory.initializeBean(AbstractAutowireCapableBeanFactory.java:1574)
> ~[spring-beans-4.3.0.RELEASE.jar!/:4.3.0.RELEASE]
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
