Return-Path: Delivered-To: apmail-camel-users-archive@www.apache.org Received: (qmail 90639 invoked from network); 24 Jun 2010 17:29:52 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 24 Jun 2010 17:29:52 -0000 Received: (qmail 89417 invoked by uid 500); 24 Jun 2010 17:29:52 -0000 Delivered-To: apmail-camel-users-archive@camel.apache.org Received: (qmail 89254 invoked by uid 500); 24 Jun 2010 17:29:51 -0000 Mailing-List: contact users-help@camel.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@camel.apache.org Delivered-To: mailing list users@camel.apache.org Received: (qmail 89245 invoked by uid 99); 24 Jun 2010 17:29:51 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 24 Jun 2010 17:29:51 +0000 X-ASF-Spam-Status: No, hits=1.6 required=10.0 tests=AWL,HTML_MESSAGE,SPF_NEUTRAL X-Spam-Check-By: apache.org Received-SPF: neutral (athena.apache.org: local policy) Received: from [81.16.53.101] (HELO pm1.terions.de) (81.16.53.101) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 24 Jun 2010 17:29:43 +0000 Received: (qmail 18365 invoked by uid 98); 24 Jun 2010 17:29:17 -0000 Received: from unknown (HELO MacHal.local) (mailing-lists@dueppe.com@80.226.224.58) by 0 with ESMTPA; 24 Jun 2010 17:29:17 -0000 Message-ID: <4C2395ED.8040008@dueppe.com> Date: Thu, 24 Jun 2010 19:29:17 +0200 From: =?ISO-8859-1?Q?Ingo_D=FCppe?= User-Agent: Mozilla/5.0 (Macintosh; U; Intel Mac OS X 10.6; de; rv:1.9.1.10) Gecko/20100512 Lightning/1.0b1 Thunderbird/3.0.5 MIME-Version: 1.0 To: users@camel.apache.org Subject: Re: Clustering with camel-quartz References: <4C03E1E0.2050407@dueppe.com> <4C03E86D.1030406@dueppe.com> <4C077F28.8030006@dueppe.com> <4C081100.2090306@dueppe.com> <4C08F364.3080407@dueppe.com> <4C20C519.7020503@dueppe.com> <4C20DADE.6020509@dueppe.com> <4C2168C5.7080509@gmail.com> In-Reply-To: <4C2168C5.7080509@gmail.com> X-Enigmail-Version: 1.0.1 Content-Type: multipart/alternative; boundary="------------040308060102010506070003" --------------040308060102010506070003 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit 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.GenericApplicationContext@46dd75a4: display name [org.springframework.context.support.GenericApplicationContext@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.GenericApplicationContext@46dd75a4]: org.springframework.beans.factory.support.DefaultListableBeanFactory@28caea19 DEBUG - SpringCamelContext - Set the application context classloader to: sun.misc.Launcher$AppClassLoader@32f4a24a DEBUG - AbstractCamelContextFactoryBean - Found JAXB created routes: [] INFO - DefaultListableBeanFactory - Pre-instantiating singletons in org.springframework.beans.factory.support.DefaultListableBeanFactory@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.GenericApplicationContext@46dd75a4: display name [org.springframework.context.support.GenericApplicationContext@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.JmxMBeanServer@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.SharedProducerServicePool@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.EventComponent@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.MockComponent@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$MockProcessor@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.QuartzComponent@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$MockProcessor@79fb80c9]]]] with name: RedeliveryErrorHandler-AsyncRedeliveryTask. [poolSize=10]. -> java.util.concurrent.ScheduledThreadPoolExecutor@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.GenericApplicationContext@46dd75a4: display name [org.springframework.context.support.GenericApplicationContext@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.GenericApplicationContext@46dd75a4: display name [org.springframework.context.support.GenericApplicationContext@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.DefaultListableBeanFactory@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.DefaultShutdownStrategy@3ddd5a3d with name: ShutdownTask. -> java.util.concurrent.Executors$FinalizableDelegatedExecutorService@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$FinalizableDelegatedExecutorService@7b60e796 INFO - DefaultInflightRepository - Shutting down with no inflight exchanges. DEBUG - SharedProducerServicePool - Stopping service pool: org.apache.camel.impl.SharedProducerServicePool@14028bda DEBUG - DefaultExecutorServiceStrategy - ShutdownNow ExecutorService: java.util.concurrent.ScheduledThreadPoolExecutor@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 --------------040308060102010506070003--