Hello,
I found still some issues about clustering camel-quartz component (based
on the current trunk version)
First, why are stateful triggers are unscheduled on a graceful shutdown.
I guess this causes, that the trigger is deleted within the database. So
not only the node that is shutting down loses the triggers also the
other nodes in the cluster will lost their triggers.
Maybe checking if the trigger is stateful before removing on shutdown
will help.
Second, see the log below. It seems that the default trigger is fired
before it is resumed.
Any suggestions?
Regards
Ingo
INFO - TestContextManager - @TestExecutionListeners is not
present for class [class
crowdcode.quartz.cluster.demo.QuartzClusterTest]: using defaults.
INFO - XmlBeanDefinitionReader - Loading XML bean definitions
from class path resource [context-test.xml]
INFO - CamelNamespaceHandler -
camel-osgi.jar/camel-spring-osgi.jar not detected in classpath
DEBUG - CamelNamespaceHandler - Using
org.apache.camel.spring.CamelContextFactoryBean as
CamelContextBeanDefinitionParser
DEBUG - CamelNamespaceHandler - Registered default:
org.apache.camel.spring.CamelProducerTemplateFactoryBean with id:
template on camel context: camel-quartz
DEBUG - CamelNamespaceHandler - Registered default:
org.apache.camel.spring.CamelConsumerTemplateFactoryBean with id:
consumerTemplate on camel context: camel-quartz
INFO - GenericApplicationContext - Refreshing
org.springframework.context.support.genericapplicationcont...@46dd75a4:
display name
[org.springframework.context.support.genericapplicationcont...@46dd75a4];
startup
date [Thu Jun 24 19:20:18 CEST 2010]; root of context hierarchy
INFO - GenericApplicationContext - Bean factory for application
context
[org.springframework.context.support.genericapplicationcont...@46dd75a4]:
org.springframework.beans.factory.support.defaultlistablebeanfact...@28caea19
DEBUG - SpringCamelContext - Set the application context
classloader to: sun.misc.launcher$appclassloa...@32f4a24a
DEBUG - AbstractCamelContextFactoryBean - Found JAXB created routes: []
INFO - DefaultListableBeanFactory - Pre-instantiating singletons in
org.springframework.beans.factory.support.defaultlistablebeanfact...@28caea19:
defining beans
[template,consumerTemplate,camel-quartz:beanPostProcessor,camel-quartz,org.springframework.context.annotation.internalCommonAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalRequiredAnnotationProcessor];
root of factory hierarchy
DEBUG - SpringCamelContext - onApplicationEvent:
org.springframework.context.event.contextrefreshedevent[source=org.springframework.context.support.genericapplicationcont...@46dd75a4:
display name
[org.springframework.context.support.genericapplicationcont...@46dd75a4];
startup
date [Thu Jun 24 19:20:18 CEST 2010]; root of context hierarchy]
INFO - DefaultCamelContext - Apache Camel 2.4-SNAPSHOT
(CamelContext: camel-quartz) is starting
INFO - DefaultCamelContext - JMX enabled. Using
ManagedManagementStrategy.
DEBUG - DefaultManagementAgent - Starting JMX agent on server:
com.sun.jmx.mbeanserver.jmxmbeanser...@4aa0c486
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=context,name="camel-quartz"
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=DefaultTypeConverter(0x2bbef4c6)
DEBUG - DefaultTypeConverter - Loading type converters ...
INFO - AnnotationTypeConverterLoader - Loading file
META-INF/services/org/apache/camel/TypeConverter to retrieve list of
packages, from url:
jar:file:/Users/idueppe/.m2/repository/org/apache/camel/camel-core/2.4-SNAPSHOT/camel-core-2.4-SNAPSHOT.jar!/META-INF/services/org/apache/camel/TypeConverter
DEBUG - DefaultPackageScanClassResolver - Searching for annotations of
org.apache.camel.Converter in packages:
[org.apache.camel.component.file, org.apache.camel.component.bean,
org.apache.camel.converter]
DEBUG - DefaultPackageScanClassResolver - Found: [class
org.apache.camel.component.file.GenericFileConverter, class
org.apache.camel.component.bean.BeanConverter, class
org.apache.camel.converter.CamelConverter, class
org.apache.camel.converter.CollectionConverter, class
org.apache.camel.converter.IOConverter, class
org.apache.camel.converter.NIOConverter, class
org.apache.camel.converter.ObjectConverter, class
org.apache.camel.converter.TimePatternConverter, class
org.apache.camel.converter.jaxp.DomConverter, class
org.apache.camel.converter.jaxp.StaxConverter, class
org.apache.camel.converter.jaxp.StreamSourceConverter, class
org.apache.camel.converter.jaxp.XmlConverter, class
org.apache.camel.converter.stream.StreamCacheConverter]
INFO - AnnotationTypeConverterLoader - Found 3 packages with 13
@Converter classes to load
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.component.file.GenericFileConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.component.bean.BeanConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.CamelConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.CollectionConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.IOConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.NIOConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.ObjectConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.TimePatternConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.jaxp.DomConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.jaxp.StaxConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.jaxp.StreamSourceConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.jaxp.XmlConverter
DEBUG - AnnotationTypeConverterLoader - Loading converter class:
org.apache.camel.converter.stream.StreamCacheConverter
DEBUG - DefaultTypeConverter - Loading type converters done
INFO - DefaultTypeConverter - Loaded 143 type converters in
0.307 seconds
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=DefaultExecutorServiceStrategy(0x2fd23e75)
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=SharedProducerServicePool(0x14028bda)
DEBUG - SharedProducerServicePool - Starting service pool:
org.apache.camel.impl.sharedproducerservicep...@14028bda
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=DefaultInflightRepository(0x35489ea3)
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=DefaultShutdownStrategy(0x3ddd5a3d)
DEBUG - DefaultComponent - Creating endpoint
uri=[spring-event://default], path=[default], parameters=[{}]
DEBUG - DefaultCamelContext - spring-event://default
converted to endpoint: Endpoint[spring-event://default] by component:
org.apache.camel.component.event.eventcompon...@9c7eb33
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=endpoints,name="spring-event://default"
DEBUG - DefaultCamelContext - Starting routes...
INFO - DefaultCamelContext - Started 0 routes
INFO - DefaultCamelContext - Apache Camel 2.4-SNAPSHOT
(CamelContext: camel-quartz) started in 0.488 seconds
DEBUG - DefaultComponentResolver - Found component: mock via type:
org.apache.camel.component.mock.MockComponent via:
META-INF/services/org/apache/camel/component/mock
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=components,name="mock"
DEBUG - DefaultComponent - Creating endpoint
uri=[mock://result], path=[result], parameters=[{}]
DEBUG - DefaultCamelContext - mock://result converted to
endpoint: Endpoint[mock://result] by component:
org.apache.camel.component.mock.mockcompon...@2ca2e19e
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=endpoints,name="mock://result"
DEBUG - DefaultCamelContext - Adding routes from builder:
Routes: []
DEBUG - RouteDefinition - Using AutoStartup true on
route:
Route[[From[quartz://crowdcode/specialtrigger?stateful=true&cron=0/1+*+*+*+*+?]]
->
[process[crowdcode.quartz.cluster.demo.quartzclustertest$mockproces...@79fb80c9],
To[mock:result]]]
DEBUG - DefaultComponentResolver - Found component: quartz via
type: org.apache.camel.component.quartz.QuartzComponent via:
META-INF/services/org/apache/camel/component/quartz
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=components,name="quartz"
INFO - SchedulerSignalerImpl - Initialized Scheduler Signaller
of type: class org.quartz.core.SchedulerSignalerImpl
INFO - QuartzScheduler - Quartz Scheduler v.1.8.2 created.
INFO - JobStoreTX - Using db table-based data
access locking (synchronization).
INFO - JobStoreTX - JobStoreTX initialized.
INFO - QuartzScheduler - Scheduler meta-data: Quartz
Scheduler (v1.8.2) 'TEST' with instanceId 'MacHal.local1277400019195'
Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
NOT STARTED.
Currently in standby mode.
Number of jobs executed: 0
Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 1 threads.
Using job-store 'org.quartz.impl.jdbcjobstore.JobStoreTX' - which
supports persistence. and is clustered.
INFO - StdSchedulerFactory - Quartz scheduler 'TEST'
initialized from default resource file in Quartz package:
'quartz.properties'
INFO - StdSchedulerFactory - Quartz scheduler version: 1.8.2
INFO - QuartzComponent - Starting Quartz scheduler: TEST
DEBUG - StdRowLockSemaphore - Lock 'STATE_ACCESS' is desired
by: main
DEBUG - StdRowLockSemaphore - Lock 'STATE_ACCESS' is being
obtained: main
DEBUG - StdRowLockSemaphore - Lock 'STATE_ACCESS' given to: main
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: main
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: main
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
main
INFO - JobStoreTX - ClusterManager: detected 1
failed or restarted instances.
INFO - JobStoreTX - ClusterManager: Scanning for
instance "MacHal.local1277399858770"'s failed in-progress jobs.
INFO - JobStoreTX - ClusterManager: ......Freed 1
acquired trigger(s).
DEBUG - JobStoreTX - ClusterManager: ......Deleted 0
complete triggers(s).
DEBUG - JobStoreTX - ClusterManager: ......Scheduled
0 recoverable job(s) for recovery.
DEBUG - JobStoreTX - ClusterManager:
......Cleaned-up 0 other failed job(s).
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: main
DEBUG - StdRowLockSemaphore - Lock 'STATE_ACCESS' returned
by: main
DEBUG - JobStoreTX - ClusterManager: Check-in complete.
DEBUG - JobStoreTX - MisfireHandler: scanning for
misfires...
INFO - QuartzScheduler - Scheduler
TEST_$_MacHal.local1277400019195 started.
DEBUG - DefaultComponent - Creating endpoint
uri=[quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true],
path=[crowdcode/specialtrigger], parameters=[{cron=0/1 * * * * ?,
stateful=true}]
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: QuartzScheduler_TEST-MacHal.local1277400019195_MisfireHandler
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: QuartzScheduler_TEST-MacHal.local1277400019195_MisfireHandler
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
QuartzScheduler_TEST-MacHal.local1277400019195_MisfireHandler
INFO - JobStoreTX - Handling 1 trigger(s) that
missed their scheduled fire-time.
DEBUG - DefaultCamelContext -
quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
converted to endpoint:
Endpoint[quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true]
by component: org.apache.camel.component.quartz.quartzcompon...@52c8c6d9
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=QuartzEndpoint(0x7b76fb04)
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=endpoints,name="quartz://crowdcode/specialtrigger\?cron=0%2F1+\*+\*+\*+\*+%3F&stateful=true"
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: QuartzScheduler_TEST-MacHal.local1277400019195_MisfireHandler
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_QuartzSchedulerThread
DEBUG - SimpleJobFactory - Producing instance of Job
'DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true',
class=org.apache.camel.component.quartz.StatefulCamelJob
DEBUG - JobRunShell - Calling execute on job
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
DEBUG - QuartzEndpoint - Firing Quartz Job with context:
JobExecutionContext: trigger: 'crowdcode.specialtrigger job:
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
fireTime: 'Thu Jun 24 19:20:19 CEST 2010 scheduledFireTime: Thu Jun 24
19:20:19 CEST 2010 previousFireTime: 'Thu Jun 24 19:17:43 CEST 2010
nextFireTime: Thu Jun 24 19:20:20 CEST 2010 isRecovering: false
refireCount: 0
ERROR - QuartzEndpoint - Error processing exchange.
Exchange[Message: [Body is null]]. Caused by:
[java.lang.IllegalStateException - No processors available to process
Exchange[Message: [Body is null]]]
INFO - JobRunShell - Job
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
threw a JobExecutionException:
org.quartz.JobExecutionException: java.lang.IllegalStateException: No
processors available to process Exchange[Message: [Body is null]] [See
nested exception: java.lang.IllegalStateException: No processors
available to process Exchange[Message: [Body is null]]]
at
org.apache.camel.component.quartz.QuartzEndpoint.onJobExecute(QuartzEndpoint.java:111)
at
org.apache.camel.component.quartz.StatefulCamelJob.execute(StatefulCamelJob.java:44)
at org.quartz.core.JobRunShell.run(JobRunShell.java:216)
at
org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:549)
Caused by: java.lang.IllegalStateException: No processors available to
process Exchange[Message: [Body is null]]
at
org.apache.camel.processor.loadbalancer.QueueLoadBalancer.process(QueueLoadBalancer.java:41)
at
org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:53)
at
org.apache.camel.processor.loadbalancer.QueueLoadBalancer.process(QueueLoadBalancer.java:63)
at
org.apache.camel.component.quartz.QuartzEndpoint.onJobExecute(QuartzEndpoint.java:97)
... 3 more
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_Worker-1
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=tracer,name=Tracer(0x7fdb04ed)
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_Worker-1
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=errorhandlers,name="DefaultErrorHandlerBuilder(ref:CamelDefaultErrorHandlerBuilder)"
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=routes,name="route1"
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=threadpools,name=ScheduledThreadPoolExecutor(0x6f9702b1)
DEBUG - DefaultExecutorServiceStrategy - Created new scheduled thread
pool for source:
DefaultErrorHandler[Instrumentation:process[traceinterceptor[process[crowdcode.quartz.cluster.demo.quartzclustertest$mockproces...@79fb80c9]]]]
with name: RedeliveryErrorHandler-AsyncRedeliveryTask. [poolSize=10]. ->
java.util.concurrent.scheduledthreadpoolexecu...@6f9702b1
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=ProducerCache(0x4ad9d6ae)
DEBUG - MockEndpoint$1 - Starting producer:
Producer[mock://result]
DEBUG - ProducerCache - Adding to producer cache with
key: Endpoint[mock://result] for producer: Producer[mock://result]
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=processors,name=SendProcessor(0x2537e19e)
DEBUG - DefaultCamelContext - Starting consumer (order: 1000)
on route: route1
DEBUG - DefaultManagementAgent - Registered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=consumers,name=QuartzConsumer(0x1bd4f279)
DEBUG - QuartzConsumer - Starting consumer:
Consumer[quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true]
DEBUG - QuartzComponent - Resuming job using trigger:
crowdcode/specialtrigger
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: main
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: main
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
main
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: main
INFO - MockEndpoint - Asserting:
Endpoint[mock://result] is satisfied
DEBUG - MockEndpoint - Waiting on the latch for: 10000
millis
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_QuartzSchedulerThread
DEBUG - SimpleJobFactory - Producing instance of Job
'DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true',
class=org.apache.camel.component.quartz.StatefulCamelJob
DEBUG - JobRunShell - Calling execute on job
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
DEBUG - QuartzEndpoint - Firing Quartz Job with context:
JobExecutionContext: trigger: 'crowdcode.specialtrigger job:
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
fireTime: 'Thu Jun 24 19:20:20 CEST 2010 scheduledFireTime: Thu Jun 24
19:20:20 CEST 2010 previousFireTime: 'Thu Jun 24 19:20:19 CEST 2010
nextFireTime: Thu Jun 24 19:20:21 CEST 2010 isRecovering: false
refireCount: 0
DEBUG - QuartzClusterTest - ##################> GOT Message
from Quartz Exchange[Message: [Body is null]]
DEBUG - QuartzClusterTest - ##################> GOT Message
from Quartz with Body null
DEBUG - SendProcessor - >>>> Endpoint[mock://result]
Exchange[Message: Hello Again for 1]
DEBUG - MockEndpoint - mock://result >>>> 1 :
Exchange[Message: Hello Again for 1] with body: Hello Again for 1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_QuartzSchedulerThread
DEBUG - SimpleJobFactory - Producing instance of Job
'DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true',
class=org.apache.camel.component.quartz.StatefulCamelJob
DEBUG - JobRunShell - Calling execute on job
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
DEBUG - QuartzEndpoint - Firing Quartz Job with context:
JobExecutionContext: trigger: 'crowdcode.specialtrigger job:
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
fireTime: 'Thu Jun 24 19:20:21 CEST 2010 scheduledFireTime: Thu Jun 24
19:20:21 CEST 2010 previousFireTime: 'Thu Jun 24 19:20:20 CEST 2010
nextFireTime: Thu Jun 24 19:20:22 CEST 2010 isRecovering: false
refireCount: 0
DEBUG - QuartzClusterTest - ##################> GOT Message
from Quartz Exchange[Message: [Body is null]]
DEBUG - QuartzClusterTest - ##################> GOT Message
from Quartz with Body null
DEBUG - SendProcessor - >>>> Endpoint[mock://result]
Exchange[Message: Hello Again for 2]
DEBUG - MockEndpoint - mock://result >>>> 2 :
Exchange[Message: Hello Again for 2] with body: Hello Again for 2
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_QuartzSchedulerThread
DEBUG - SimpleJobFactory - Producing instance of Job
'DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true',
class=org.apache.camel.component.quartz.StatefulCamelJob
DEBUG - JobRunShell - Calling execute on job
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
DEBUG - QuartzEndpoint - Firing Quartz Job with context:
JobExecutionContext: trigger: 'crowdcode.specialtrigger job:
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
fireTime: 'Thu Jun 24 19:20:22 CEST 2010 scheduledFireTime: Thu Jun 24
19:20:22 CEST 2010 previousFireTime: 'Thu Jun 24 19:20:21 CEST 2010
nextFireTime: Thu Jun 24 19:20:23 CEST 2010 isRecovering: false
refireCount: 0
DEBUG - QuartzClusterTest - ##################> GOT Message
from Quartz Exchange[Message: [Body is null]]
DEBUG - QuartzClusterTest - ##################> GOT Message
from Quartz with Body null
DEBUG - SendProcessor - >>>> Endpoint[mock://result]
Exchange[Message: Hello Again for 3]
DEBUG - MockEndpoint - mock://result >>>> 3 :
Exchange[Message: Hello Again for 3] with body: Hello Again for 3
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_QuartzSchedulerThread
DEBUG - SimpleJobFactory - Producing instance of Job
'DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true',
class=org.apache.camel.component.quartz.StatefulCamelJob
DEBUG - JobRunShell - Calling execute on job
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
DEBUG - QuartzEndpoint - Firing Quartz Job with context:
JobExecutionContext: trigger: 'crowdcode.specialtrigger job:
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
fireTime: 'Thu Jun 24 19:20:23 CEST 2010 scheduledFireTime: Thu Jun 24
19:20:23 CEST 2010 previousFireTime: 'Thu Jun 24 19:20:22 CEST 2010
nextFireTime: Thu Jun 24 19:20:24 CEST 2010 isRecovering: false
refireCount: 0
DEBUG - QuartzClusterTest - ##################> GOT Message
from Quartz Exchange[Message: [Body is null]]
DEBUG - QuartzClusterTest - ##################> GOT Message
from Quartz with Body null
DEBUG - SendProcessor - >>>> Endpoint[mock://result]
Exchange[Message: Hello Again for 4]
DEBUG - MockEndpoint - mock://result >>>> 4 :
Exchange[Message: Hello Again for 4] with body: Hello Again for 4
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_QuartzSchedulerThread
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_QuartzSchedulerThread
DEBUG - SimpleJobFactory - Producing instance of Job
'DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true',
class=org.apache.camel.component.quartz.StatefulCamelJob
DEBUG - JobRunShell - Calling execute on job
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
DEBUG - QuartzEndpoint - Firing Quartz Job with context:
JobExecutionContext: trigger: 'crowdcode.specialtrigger job:
DEFAULT.quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true
fireTime: 'Thu Jun 24 19:20:24 CEST 2010 scheduledFireTime: Thu Jun 24
19:20:24 CEST 2010 previousFireTime: 'Thu Jun 24 19:20:23 CEST 2010
nextFireTime: Thu Jun 24 19:20:25 CEST 2010 isRecovering: false
refireCount: 0
DEBUG - QuartzClusterTest - ##################> GOT Message
from Quartz Exchange[Message: [Body is null]]
DEBUG - QuartzClusterTest - ##################> GOT Message
from Quartz with Body null
DEBUG - SendProcessor - >>>> Endpoint[mock://result]
Exchange[Message: Hello Again for 5]
DEBUG - MockEndpoint - mock://result >>>> 5 :
Exchange[Message: Hello Again for 5] with body: Hello Again for 5
DEBUG - MockEndpoint - Took 4145 millis to complete latch
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is
desired by: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' is being
obtained: TEST_Worker-1
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' given to:
TEST_Worker-1
INFO - GenericApplicationContext - Closing
org.springframework.context.support.genericapplicationcont...@46dd75a4:
display name
[org.springframework.context.support.genericapplicationcont...@46dd75a4];
startup
date [Thu Jun 24 19:20:18 CEST 2010]; root of context hierarchy
DEBUG - SpringCamelContext - onApplicationEvent:
org.springframework.context.event.contextclosedevent[source=org.springframework.context.support.genericapplicationcont...@46dd75a4:
display name
[org.springframework.context.support.genericapplicationcont...@46dd75a4];
startup
date [Thu Jun 24 19:20:18 CEST 2010]; root of context hierarchy]
INFO - DefaultListableBeanFactory - Destroying singletons in
org.springframework.beans.factory.support.defaultlistablebeanfact...@28caea19:
defining beans
[template,consumerTemplate,camel-quartz:beanPostProcessor,camel-quartz,org.springframework.context.annotation.internalCommonAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalRequiredAnnotationProcessor];
root of factory hierarchy
INFO - DefaultCamelContext - Apache Camel 2.4-SNAPSHOT
(CamelContext:camel-quartz) is shutting down
INFO - DefaultShutdownStrategy - Starting to graceful shutdown 1
routes (timeout 300 seconds)
DEBUG - DefaultExecutorServiceStrategy - Created new single thread pool
for source: org.apache.camel.impl.defaultshutdownstrat...@3ddd5a3d with
name: ShutdownTask. ->
java.util.concurrent.executors$finalizabledelegatedexecutorserv...@7b60e796
DEBUG - DefaultShutdownStrategy - There are 1 routes to shutdown
DEBUG - QuartzConsumer - Stopping consumer:
Consumer[quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true]
DEBUG - MockEndpoint$1 - Stopping producer:
Producer[mock://result]
DEBUG - DefaultShutdownStrategy - Shutdown complete for:
Consumer[quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true]
INFO - DefaultShutdownStrategy - Route: route1 shutdown
complete, was consuming from:
Endpoint[quartz://crowdcode/specialtrigger?cron=0%2F1+*+*+*+*+%3F&stateful=true]
INFO - DefaultShutdownStrategy - Graceful shutdown of 1 routes
completed in 0 seconds
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=routes,name="route1"
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=consumers,name=QuartzConsumer(0x1bd4f279)
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=processors,name=SendProcessor(0x2537e19e)
INFO - QuartzComponent - There are still 1 jobs
registered in the Quartz scheduler: TEST
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=context,name="camel-quartz"
DEBUG - DefaultExecutorServiceStrategy - ShutdownNow ExecutorService:
java.util.concurrent.executors$finalizabledelegatedexecutorserv...@7b60e796
INFO - DefaultInflightRepository - Shutting down with no inflight
exchanges.
DEBUG - SharedProducerServicePool - Stopping service pool:
org.apache.camel.impl.sharedproducerservicep...@14028bda
DEBUG - DefaultExecutorServiceStrategy - ShutdownNow ExecutorService:
java.util.concurrent.scheduledthreadpoolexecu...@6f9702b1
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=errorhandlers,name="DefaultErrorHandlerBuilder(ref:CamelDefaultErrorHandlerBuilder)"
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=ProducerCache(0x4ad9d6ae)
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=DefaultShutdownStrategy(0x3ddd5a3d)
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=endpoints,name="mock://result"
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=endpoints,name="spring-event://default"
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=tracer,name=Tracer(0x7fdb04ed)
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=QuartzEndpoint(0x7b76fb04)
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=DefaultInflightRepository(0x35489ea3)
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=components,name="mock"
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=DefaultTypeConverter(0x2bbef4c6)
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=components,name="quartz"
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=endpoints,name="quartz://crowdcode/specialtrigger\?cron=0%2F1+\*+\*+\*+\*+%3F&stateful=true"
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=threadpools,name=ScheduledThreadPoolExecutor(0x6f9702b1)
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=DefaultExecutorServiceStrategy(0x2fd23e75)
DEBUG - DefaultManagementAgent - Unregistered MBean with
objectname:
org.apache.camel:context=MacHal.local/camel-quartz,type=services,name=SharedProducerServicePool(0x14028bda)
INFO - DefaultCamelContext - Uptime: 5.480 seconds
INFO - DefaultCamelContext - Apache Camel 2.4-SNAPSHOT
(CamelContext: camel-quartz) is shutdown in 0.022 seconds
DEBUG - StdRowLockSemaphore - Lock 'TRIGGER_ACCESS' returned
by: TEST_Worker-1
