after moving from camel-quartz 2.4.0 to 2.6.0 I started getting exceptions
when the trigger is fired:
10:39:47.776 [DefaultQuartzScheduler_Worker-9] ERROR
org.quartz.core.JobRunShell - Job DEFAULT.quartz-endpoint140 threw an
unhandled Exception:
org.apache.camel.ResolveEndpointFailedException: Failed to resolve endpoint:
quartz://Tasks/22 due to: A Quartz job already exists with the name/group:
22_trigger/Tasks
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:449)
~[bundlefile:2.6.0]
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:463)
~[bundlefile:2.6.0]
at org.apache.camel.component.quartz.CamelJob.execute(CamelJob.java:50)
~[bundlefile:2.6.0]
at org.quartz.core.JobRunShell.run(JobRunShell.java:202)
~[bundlefile:1.6.2]
at
org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:525)
[bundlefile:1.6.2]
Caused by: java.lang.IllegalArgumentException: A Quartz job already exists
with the name/group: 22_trigger/Tasks
at
org.apache.camel.component.quartz.QuartzComponent.createEndpoint(QuartzComponent.java:122)
~[bundlefile:2.6.0]
at
org.apache.camel.component.quartz.QuartzComponent.createEndpoint(QuartzComponent.java:54)
~[bundlefile:2.6.0]
at
org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:75)
~[bundlefile:2.6.0]
at
org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:431)
~[bundlefile:2.6.0]
... 4 common frames omitted
maybe I am adding the the QuartzEndpoint the wrong way, this is the way I am
doing it ( used to work ):
camelContext.addRoutes(new RouteBuilder() {
@Override
public void configure() throws Exception {
QuartzComponent quartzComponent = (QuartzComponent)
camelContext.getComponent("quartz");
QuartzEndpoint endpoint = new QuartzEndpoint(null,
quartzComponent);
Trigger trigger = createTrigger();
trigger.setGroup("Tasks");
trigger.setName(id);
endpoint.setTrigger(trigger);
JobDataMap dataMap = createJobDataMap();
trigger.setJobDataMap(dataMap);
camelContext.addEndpoint("quart_qtx_" + trigger.getName(),
endpoint);
from("quart_qtx_" + trigger.getName())
...
.to("direct:mock_dest");
}
});
--
View this message in context:
http://camel.465427.n5.nabble.com/updating-from-camel-quartz-2-4-to-2-6-tp4271113p4271113.html
Sent from the Camel - Users mailing list archive at Nabble.com.
