[
https://issues.apache.org/activemq/browse/CAMEL-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=53903#action_53903
]
Charles Moulliard commented on CAMEL-1940:
------------------------------------------
I have retested with build - 31/08/2009 of camel-core / camel-spring but the
problem is still there.
> pollEnrich does not work with queue and quartz or timer endpoints
> -----------------------------------------------------------------
>
> Key: CAMEL-1940
> URL: https://issues.apache.org/activemq/browse/CAMEL-1940
> Project: Apache Camel
> Issue Type: Bug
> Reporter: Charles Moulliard
>
> Hi,
> In the following route example, the pollenrich processor is never called
> {code}
> <camel:from
> uri="quartz://x3sReporting/clientError?cron=0+0/5+9-18+?+*+MON-FRI"/>
> <camel:pollEnrich uri="queuingservice:x3s:reporting"
> strategyRef="queueAggregator"/>
> <camel:transacted ref="PROPAGATION_REQUIRED_NEW" />
> <camel:choice>
> <camel:when>
> <camel:simple>${body} != null</camel:simple>
> <camel:doTry>
> <camel:marshal ref="csvAuditBindyDataFormat" />
> {code}
> Definiton of the AggregationStrategy class used
> {code}
> public class QueueAggregator implements AggregationStrategy {
>
> private static final transient Log LOG =
> LogFactory.getLog(QueueAggregator.class);
> public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
> if (newExchange == null) {
> LOG.info("Old object received (null exchange) : " +
> oldExchange.getIn().getBody().toString());
> return oldExchange;
> }
> Object oldBody = oldExchange.getIn().getBody();
> LOG.info("Old object received : " + oldBody.toString());
> Object newBody = newExchange.getIn().getBody();
> LOG.info("New object received : " + newBody.toString());
> oldExchange.getIn().setBody(newBody);
> return oldExchange;
> }
> }
> {code}
> Unfortunately, the aggregator is not called (no info trace in the LOG) and
> the body object send to the endpoint (marshall) is of type
> org.quartz.JobDetail
> {code}
> 11:10:02,703 | INFO | heduler_Worker-1 | TraceInterceptor |
> rg.apache.camel.processor.Logger 88 |
> ID-dell-charles-3372-1251127950838-0-10 >>>
> from(quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI) -->
> ref:PROPAGATION_REQUIRED_NEW, Pattern:InOnly,
> Headers:{triggerGroup=x3sReporting,
> jobinstance=org.apache.camel.component.quartz.camel...@1264f27,
> nextFireTime=Tue Aug 25 11:15:00 CEST 2009, previousFireTime=null,
> jobDetail=JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false,
> triggerName=clientError, trigger=Trigger 'x3sReporting.clientError':
> triggerClass: 'org.quartz.CronTrigger isVolatile: false calendar: 'null'
> misfireInstruction: 0 nextFireTime: Tue Aug 25 11:15:00 CEST 2009,
> scheduler=org.quartz.impl.stdschedu...@16975d, jobRunTime=-1,
> scheduledFireTime=Tue Aug 25 11:10:00 CEST 2009, result=null, calendar=null,
> mergedjobdatamap=org.quartz.jobdata...@ccc462dc, refireCount=0, fireTime=Tue
> Aug 25 11:10:00 CEST 2009}, BodyType:org.quartz.JobDetail, Body:JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false
> 11:10:02,718 | INFO | heduler_Worker-1 | TraceInterceptor |
> rg.apache.camel.processor.Logger 88 |
> ID-dell-charles-3372-1251127950838-0-10 >>> ref:PROPAGATION_REQUIRED_NEW -->
> Choice, Pattern:InOnly, Headers:{triggerGroup=x3sReporting,
> jobinstance=org.apache.camel.component.quartz.camel...@1264f27,
> nextFireTime=Tue Aug 25 11:15:00 CEST 2009, previousFireTime=null,
> jobDetail=JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false,
> triggerName=clientError, trigger=Trigger 'x3sReporting.clientError':
> triggerClass: 'org.quartz.CronTrigger isVolatile: false calendar: 'null'
> misfireInstruction: 0 nextFireTime: Tue Aug 25 11:15:00 CEST 2009,
> scheduler=org.quartz.impl.stdschedu...@16975d, jobRunTime=-1,
> scheduledFireTime=Tue Aug 25 11:10:00 CEST 2009, result=null, calendar=null,
> mergedjobdatamap=org.quartz.jobdata...@ccc462dc, refireCount=0, fireTime=Tue
> Aug 25 11:10:00 CEST 2009}, BodyType:org.quartz.JobDetail, Body:JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false
> 11:10:02,734 | INFO | heduler_Worker-1 | TraceInterceptor |
> rg.apache.camel.processor.Logger 88 |
> ID-dell-charles-3372-1251127950838-0-10 >>> Choice --> Try, Pattern:InOnly,
> Headers:{triggerGroup=x3sReporting,
> jobinstance=org.apache.camel.component.quartz.camel...@1264f27,
> nextFireTime=Tue Aug 25 11:15:00 CEST 2009, previousFireTime=null,
> jobDetail=JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false,
> triggerName=clientError, trigger=Trigger 'x3sReporting.clientError':
> triggerClass: 'org.quartz.CronTrigger isVolatile: false calendar: 'null'
> misfireInstruction: 0 nextFireTime: Tue Aug 25 11:15:00 CEST 2009,
> scheduler=org.quartz.impl.stdschedu...@16975d, jobRunTime=-1,
> scheduledFireTime=Tue Aug 25 11:10:00 CEST 2009, result=null, calendar=null,
> mergedjobdatamap=org.quartz.jobdata...@ccc462dc, refireCount=0, fireTime=Tue
> Aug 25 11:10:00 CEST 2009}, BodyType:org.quartz.JobDetail, Body:JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false
> 11:10:02,734 | INFO | heduler_Worker-1 | TraceInterceptor |
> rg.apache.camel.processor.Logger 88 |
> ID-dell-charles-3372-1251127950838-0-10 >>> Try -->, Pattern:InOnly,
> Headers:{triggerGroup=x3sReporting,
> jobinstance=org.apache.camel.component.quartz.camel...@1264f27,
> nextFireTime=Tue Aug 25 11:15:00 CEST 2009, previousFireTime=null,
> jobDetail=JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false,
> triggerName=clientError, trigger=Trigger 'x3sReporting.clientError':
> triggerClass: 'org.quartz.CronTrigger isVolatile: false calendar: 'null'
> misfireInstruction: 0 nextFireTime: Tue Aug 25 11:15:00 CEST 2009,
> scheduler=org.quartz.impl.stdschedu...@16975d, jobRunTime=-1,
> scheduledFireTime=Tue Aug 25 11:10:00 CEST 2009, result=null, calendar=null,
> mergedjobdatamap=org.quartz.jobdata...@ccc462dc, refireCount=0, fireTime=Tue
> Aug 25 11:10:00 CEST 2009}, BodyType:org.quartz.JobDetail, Body:JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false
> 11:10:03,171 | INFO | heduler_Worker-1 | TraceInterceptor |
> rg.apache.camel.processor.Logger 166 |
> ID-dell-charles-3372-1251127950838-0-10 >>> Try -->, Pattern:InOnly,
> Headers:{triggerGroup=x3sReporting,
> jobinstance=org.apache.camel.component.quartz.camel...@1264f27,
> nextFireTime=Tue Aug 25 11:15:00 CEST 2009, previousFireTime=null,
> jobDetail=JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false,
> triggerName=clientError, trigger=Trigger 'x3sReporting.clientError':
> triggerClass: 'org.quartz.CronTrigger isVolatile: false calendar: 'null'
> misfireInstruction: 0 nextFireTime: Tue Aug 25 11:15:00 CEST 2009,
> scheduler=org.quartz.impl.stdschedu...@16975d, jobRunTime=-1,
> scheduledFireTime=Tue Aug 25 11:10:00 CEST 2009, result=null, calendar=null,
> mergedjobdatamap=org.quartz.jobdata...@ccc462dc, refireCount=0, fireTime=Tue
> Aug 25 11:10:00 CEST 2009}, BodyType:org.quartz.JobDetail, Body:JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false, Exception:
> java.lang.ClassCastException: org.quartz.JobDetail
> 11:10:03,171 | INFO | heduler_Worker-1 | TraceInterceptor |
> rg.apache.camel.processor.Logger 88 |
> ID-dell-charles-3372-1251127950838-0-11 >>> -->
> log://com.xpectis.x3s?level=INFO&multiline=true&showCaughtException=true&showException=true&showStackTrace=true,
> Pattern:InOnly, Headers:{calendar=null, scheduledFireTime=Tue Aug 25
> 11:10:00 CEST 2009, trigger=Trigger 'x3sReporting.clientError':
> triggerClass: 'org.quartz.CronTrigger isVolatile: false calendar: 'null'
> misfireInstruction: 0 nextFireTime: Tue Aug 25 11:15:00 CEST 2009,
> triggerGroup=x3sReporting, previousFireTime=null, jobRunTime=-1,
> jobDetail=JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false, result=null,
> triggerName=clientError, fireTime=Tue Aug 25 11:10:00 CEST 2009,
> mergedjobdatamap=org.quartz.jobdata...@ccc462dc,
> jobinstance=org.apache.camel.component.quartz.camel...@1264f27,
> scheduler=org.quartz.impl.stdschedu...@16975d, refireCount=0,
> nextFireTime=Tue Aug 25 11:15:00 CEST 2009}, BodyType:org.quartz.JobDetail,
> Body:JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false
> 11:10:03,187 | INFO | heduler_Worker-1 | x3s |
> rg.apache.camel.processor.Logger 88 | Exchange[
> , BodyType:org.quartz.JobDetail
> , Body:JobDetail
> 'DEFAULT.quartz://x3sReporting/clientError?cron=0+0%2F5+9-18+%3F+*+MON-FRI':
> jobClass: 'org.apache.camel.component.quartz.CamelJob isStateful: false
> isVolatile: false isDurable: false requestsRecovers: false
> , CaughtExceptionType:java.lang.ClassCastException,
> CaughtExceptionMessage:org.quartz.JobDetail,
> StackTrace:java.lang.ClassCastException: org.quartz.JobDetail
> at
> org.apache.camel.dataformat.bindy.csv.BindyCsvDataFormat.marshal(BindyCsvDataFormat.java:60)
> {code}
--
This message is automatically generated by JIRA.
-
You can reply to this email to add a comment to the issue online.
