On Thu, Jun 24, 2010 at 7:29 PM, Ingo Düppe <mailing-li...@dueppe.com> wrote: > 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. >
Thanks for reporting. I have just committed a fix to trunk which only removes the job if its volatile. trunk: 957796. Volatile is the information according to the quartz API which dictates if the job should be kept in the DB or not. http://www.quartz-scheduler.org/docs/api/1.8.1/index.html Please give it a test on your system. > 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 > > > > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
