Sorry for long time, but I surrender doing this with Camel. Yesterday I done this with only Service Mix endpoints: - two HTTP consumers for receiving requests - two JMS providers for putting messages to queue - one JMS consumer who reading messages from queue and put send it to destination service
I propably will use http://activemq.apache.org/camel/throttler.html but that is easier than all JMS stuff :) Regards, Luke willem.jiang wrote: > > I just committed a test [1], which shows the same basic user story as > your example ( I take out the JBI part of HTTP BC). > It works with the latest Camel code, please check it out. > > [1]https://svn.apache.org/repos/asf/activemq/camel/trunk/tests/camel-itest/src/test/java/org/apache/camel/itest/jetty/JettyJmsTwowayTest.java > > Willem > splatch wrote: >> Result is the same - NullPointerException. >> >> >> willem.jiang wrote: >> >>> Hi >>> >>> Can you try the below code which just set the out message's body ? >>> >>> class EndProcessor implements Processor { >>> >>> public void process(Exchange exchange) { >>> System.out.println("======= > " + >>> exchange.getIn().getBody(String.class)); >>> exchange.getOut().setBody("<message>out</message>"); >>> } >>> } >>> >>> >>> Willem >>> >>> >>> splatch wrote: >>> >>>> When I added processor at the end of the flow I've got >>>> NullPointerException. >>>> Used processor: >>>> class EndProcessor implements Processor { >>>> >>>> public void process(Exchange exchange) { >>>> System.out.println("======= > " + >>>> exchange.getIn().getBody(String.class)); >>>> Message copy = exchange.getIn().copy(); >>>> copy.setBody("<message>out</message>"); >>>> exchange.setOut(copy); >>>> } >>>> } >>>> >>>> Stack trace: >>>> ---> properties from jms to jbi {JMSDestination=queue://foo, >>>> JMSTimestamp=1221036013825, JMSRedelivered=false, >>>> JMSExpiration=1221036033825, JMSType=null, JMSXGroupID=null, >>>> JMSMessageID=ID:war >>>> c-8a0-4650-1221036013481-0:2:1:1:1, JMSDeliveryMode=2, >>>> JMSCorrelationID=null, >>>> JMSReplyTo=temp-queue://ID:warc-8a0-4650-1221036013481-0:1:1, >>>> JMSPriority=0} >>>> ---> properties in jbi/{JMSDestination=queue://foo, >>>> JMSTimestamp=1221036013825, JMSRedelivered=false, >>>> JMSExpiration=1221036033825, >>>> JMSMessageID=ID:warc-8a0-4650-1221036013481-0:2:1:1:1, JMSDeliv >>>> eryMode=2, >>>> JMSReplyTo=temp-queue://ID:warc-8a0-4650-1221036013481-0:1:1, >>>> JMSPriority=0} >>>> processor> <message id="9">{http://stock}low</message> >>>> ---> after processing {JMSDestination=queue://foo, >>>> JMSTimestamp=1221036013825, JMSRedelivered=false, >>>> JMSExpiration=1221036033825, >>>> JMSMessageID=ID:warc-8a0-4650-1221036013481-0:2:1:1:1, JM >>>> SDeliveryMode=2, >>>> JMSReplyTo=temp-queue://ID:warc-8a0-4650-1221036013481-0:1:1, >>>> JMSPriority=0} >>>> [WARN] >>>> [org.springframework.jms.listener.DefaultMessageListenerContainer] >>>> Execution of JMS message listener failed >>>> org.apache.camel.RuntimeCamelException: java.lang.NullPointerException >>>> at >>>> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:74) >>>> at >>>> org.springframework.jms.listener.AbstractMessageListenerContainer.doInvokeListener(AbstractMessageListenerContainer.java:531) >>>> at >>>> org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:466) >>>> at >>>> org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:435) >>>> at >>>> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:322) >>>> at >>>> org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute(AbstractPollingMessageListenerContainer.java:260) >>>> at >>>> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.invokeListener(DefaultMessageListenerContainer.java:944) >>>> at >>>> org.springframework.jms.listener.DefaultMessageListenerContainer$AsyncMessageListenerInvoker.run(DefaultMessageListenerContainer.java:875) >>>> at java.lang.Thread.run(Thread.java:595) >>>> Caused by: java.lang.NullPointerException >>>> at >>>> java.io.ObjectOutputStream$BlockDataOutputStream.getUTFLength(ObjectOutputStream.java:1944) >>>> at >>>> java.io.ObjectOutputStream$BlockDataOutputStream.writeUTF(ObjectOutputStream.java:1815) >>>> at >>>> java.io.ObjectOutputStream.writeUTF(ObjectOutputStream.java:816) >>>> at >>>> org.apache.camel.converter.jaxp.StringSource.writeExternal(StringSource.java:88) >>>> at >>>> java.io.ObjectOutputStream.writeExternalData(ObjectOutputStream.java:1310) >>>> at >>>> java.io.ObjectOutputStream.writeOrdinaryObject(ObjectOutputStream.java:1288) >>>> at >>>> java.io.ObjectOutputStream.writeObject0(ObjectOutputStream.java:1079) >>>> at >>>> java.io.ObjectOutputStream.writeObject(ObjectOutputStream.java:302) >>>> at >>>> org.apache.activemq.command.ActiveMQObjectMessage.storeContent(ActiveMQObjectMessage.java:98) >>>> at >>>> org.apache.activemq.command.ActiveMQObjectMessage.setObject(ActiveMQObjectMessage.java:155) >>>> at >>>> org.apache.activemq.ActiveMQSession.createObjectMessage(ActiveMQSession.java:319) >>>> at >>>> org.apache.camel.component.jms.JmsBinding.createJmsMessage(JmsBinding.java:221) >>>> at >>>> org.apache.camel.component.jms.JmsBinding.makeJmsMessage(JmsBinding.java:136) >>>> at >>>> org.apache.camel.component.jms.EndpointMessageListener$1.createMessage(EndpointMessageListener.java:163) >>>> at >>>> org.springframework.jms.core.JmsTemplate.doSend(JmsTemplate.java:557) >>>> at >>>> org.springframework.jms.core.JmsTemplate$3.doInJms(JmsTemplate.java:528) >>>> at >>>> org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:459) >>>> at >>>> org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:526) >>>> at >>>> org.apache.camel.component.jms.EndpointMessageListener.sendReply(EndpointMessageListener.java:161) >>>> at >>>> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:71) >>>> ... 8 more >>>> >>>> >>>> >>>> willem.jiang wrote: >>>> >>>> >>>>> It looks like the jms producer can't get out message before Future >>>>> timed >>>>> out. >>>>> From your route code, you did not set the out message back. >>>>> >>>>> // endpoint only for testing >>>>> from("jbi:service:http://stock/destination";) >>>>> .to("file:log"); >>>>> >>>>> // Please using the process to set the out message >>>>> >>>>> Willem >>>>> >>>>> splatch wrote: >>>>> >>>>> >>>>>> Hello, >>>>>> I tired to create priority queue with Camel inside Service Mix, but >>>>>> after >>>>>> two days I stucked. >>>>>> >>>>>> General idea is: >>>>>> 1) one cxf endpoint on Service Mix have priority 0 >>>>>> 2) second cxf endpoint on Service Mix have priority 9 >>>>>> 3) destination service can process only one message at time >>>>>> >>>>>> I want configure only CXF and Camel endpoints, without jms queue. >>>>>> >>>>>> My routes: >>>>>> package pl.bpsa.smx3.services.router; >>>>>> >>>>>> import javax.xml.transform.dom.DOMSource; >>>>>> >>>>>> import org.apache.camel.builder.RouteBuilder; >>>>>> >>>>>> public class RoutesProvider extends RouteBuilder { >>>>>> >>>>>> @Override >>>>>> public void configure() throws Exception { >>>>>> from("jbi:service:http://stock/high";) // important messages >>>>>> .to("jms:queue:foo?priority=9"); >>>>>> from("jbi:service:http://stock/low";) >>>>>> .to("jms:queue:foo?priority=0"); >>>>>> >>>>>> from("jms:queue:foo") >>>>>> .to("jbi:service:http://stock/destination";); >>>>>> >>>>>> // endpoint only for testing >>>>>> from("jbi:service:http://stock/destination";) >>>>>> .to("file:log"); >>>>>> } >>>>>> >>>>>> } >>>>>> >>>>>> All process are stoped when camel try put message to queue. How to >>>>>> fix >>>>>> this >>>>>> issue? >>>>>> >>>>>> [DEBUG] [org.apache.camel.impl.DefaultCamelContext] Adding routes >>>>>> from: >>>>>> Routes: [Route[ [From[jbi:service:http://stock/high]] -> >>>>>> [To[jms:queue:foo?priority=9]]], Route[ [From[jbi:s >>>>>> ervice:http://stock/low]] -> [To[jms:queue:foo?priority=0]]], Route[ >>>>>> [From[jms:queue:foo]] -> [To[jbi:service:http://stock/destination]]], >>>>>> Route[ >>>>>> [From[jbi:service:http://stock/des >>>>>> tination]] -> [To[file:log]]]] routes: [] >>>>>> >>>>>> [DEBUG] [org.apache.camel.spring.SpringCamelContext] Starting the >>>>>> CamelContext now that the ApplicationContext has started >>>>>> [DEBUG] [org.apache.camel.impl.DefaultComponentResolver] Found >>>>>> component: >>>>>> jbi in registry: >>>>>> [EMAIL PROTECTED] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultCamelContext] >>>>>> jbi:service:http://stock/high converted to endpoint: >>>>>> Endpoint[service:http://stock/high] by component: >>>>>> org.apache.servicemix.cam >>>>>> [EMAIL PROTECTED] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultComponentResolver] Found >>>>>> component: >>>>>> jms in registry: [EMAIL PROTECTED] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultComponent] Creating endpoint >>>>>> uri=[jms:queue:foo?priority=9], path=[queue:foo], >>>>>> parameters=[{priority=9}] >>>>>> [DEBUG] [org.apache.camel.util.ResolverUtil] Searching for >>>>>> annotations >>>>>> of >>>>>> org.apache.camel.Converter in packages: >>>>>> [org.apache.activemq.camel.converter, org.apache.camel.converter, >>>>>> org.apache.camel.spring.converter] >>>>>> [DEBUG] [org.apache.camel.util.ResolverUtil] Loading from jar: >>>>>> E:\repository_tmp\org\apache\activemq\activemq-core\5.0.0.15-fuse\activemq-core-5.0.0.15-fuse.jar >>>>>> [DEBUG] [org.apache.camel.util.ResolverUtil] Loading from jar: >>>>>> E:\repository_tmp\org\apache\camel\camel-core\1.4.0.0-fuse\camel-core-1.4.0.0-fuse.jar >>>>>> [DEBUG] [org.apache.camel.util.ResolverUtil] Loading from jar: >>>>>> E:\repository_tmp\org\apache\camel\camel-core\1.4.0.0-fuse\camel-core-1.4.0.0-fuse-tests.jar >>>>>> [DEBUG] [org.apache.camel.util.ResolverUtil] Found: [class >>>>>> org.apache.camel.converter.CollectionConverter, class >>>>>> org.apache.camel.converter.CamelConverter, class org.apache.camel.c >>>>>> onverter.stream.StreamCacheConverter, class >>>>>> org.apache.camel.converter.IOConverter, class >>>>>> org.apache.camel.converter.jaxp.DomConverter, class >>>>>> org.apache.activemq.camel.converter.Ac >>>>>> tiveMQMessageConverter, class >>>>>> org.apache.activemq.camel.converter.ActiveMQConverter, class >>>>>> org.apache.camel.converter.NIOConverter, class >>>>>> org.apache.camel.converter.jaxp.XmlConvert >>>>>> er, class org.apache.camel.converter.jaxp.StaxConverter, class >>>>>> org.apache.camel.converter.ObjectConverter] >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: >>>>>> org.apache.camel.converter.CollectionConverter >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: org.apache.camel.converter.CamelConverter >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: >>>>>> org.apache.camel.converter.stream.StreamCacheConverter >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: org.apache.camel.converter.IOConverter >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: org.apache.camel.converter.jaxp.DomConverter >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: >>>>>> org.apache.activemq.camel.converter.ActiveMQMessageConverter >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: >>>>>> org.apache.activemq.camel.converter.ActiveMQConverter >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: org.apache.camel.converter.NIOConverter >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: org.apache.camel.converter.jaxp.XmlConverter >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: >>>>>> org.apache.camel.converter.jaxp.StaxConverter >>>>>> [DEBUG] >>>>>> [org.apache.camel.impl.converter.AnnotationTypeConverterLoader] >>>>>> Loading converter class: org.apache.camel.converter.ObjectConverter >>>>>> [DEBUG] [org.apache.camel.impl.DefaultCamelContext] >>>>>> jms:queue:foo?priority=9 >>>>>> converted to endpoint: Endpoint[jms:queue:foo?priority=9] by >>>>>> component: >>>>>> org.apache.camel.component.jms. >>>>>> [EMAIL PROTECTED] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultCamelContext] >>>>>> jbi:service:http://stock/low converted to endpoint: >>>>>> Endpoint[service:http://stock/low] by component: >>>>>> org.apache.servicemix.camel >>>>>> [EMAIL PROTECTED] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultComponent] Creating endpoint >>>>>> uri=[jms:queue:foo?priority=0], path=[queue:foo], >>>>>> parameters=[{priority=0}] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultCamelContext] >>>>>> jms:queue:foo?priority=0 >>>>>> converted to endpoint: Endpoint[jms:queue:foo?priority=0] by >>>>>> component: >>>>>> org.apache.camel.component.jms. >>>>>> [EMAIL PROTECTED] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultComponent] Creating endpoint >>>>>> uri=[jms:queue:foo], path=[queue:foo], parameters=[{}] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultCamelContext] jms:queue:foo >>>>>> converted >>>>>> to endpoint: Endpoint[jms:queue:foo] by component: >>>>>> [EMAIL PROTECTED] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultCamelContext] >>>>>> jbi:service:http://stock/destination converted to endpoint: >>>>>> Endpoint[service:http://stock/destination] by component: org.apache. >>>>>> [EMAIL PROTECTED] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultComponentResolver] Found >>>>>> component: >>>>>> file via type: org.apache.camel.component.file.FileComponent via >>>>>> META-INF/services/org/apache/camel/compon >>>>>> ent/file >>>>>> [DEBUG] [org.apache.camel.impl.DefaultComponent] Creating endpoint >>>>>> uri=[file:log], path=[log], parameters=[{}] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultCamelContext] file:log >>>>>> converted >>>>>> to >>>>>> endpoint: Endpoint[file:log] by component: >>>>>> [EMAIL PROTECTED] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultComponent] Creating endpoint >>>>>> uri=[event:default], path=[default], parameters=[{}] >>>>>> [DEBUG] [org.apache.camel.impl.DefaultCamelContext] event:default >>>>>> converted >>>>>> to endpoint: Endpoint[event:default] by component: >>>>>> [EMAIL PROTECTED] >>>>>> d >>>>>> test >>>>>> [DEBUG] >>>>>> [org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate] >>>>>> Executing callback on JMS Session: ActiveMQSession >>>>>> {id=ID:warc-8a0-3554-1220961055917-0:2:1,started=false >>>>>> } >>>>>> [DEBUG] [org.apache.camel.component.jms.JmsProducer] >>>>>> Endpoint[jms:queue:foo?priority=0] sending JMS message: >>>>>> ActiveMQObjectMessage {commandId = 0, responseRequired = false, >>>>>> message >>>>>> Id = null, originalDestination = null, originalTransactionId = null, >>>>>> producerId = null, destination = null, transactionId = null, >>>>>> expiration >>>>>> = >>>>>> 0, >>>>>> timestamp = 0, arrival = 0, broker >>>>>> InTime = 0, brokerOutTime = 0, correlationId = null, replyTo = >>>>>> temp-queue://ID:warc-8a0-3554-1220961055917-0:1:1, persistent = >>>>>> false, >>>>>> type >>>>>> = null, priority = 0, groupID = null, gro >>>>>> upSequence = 0, targetConsumerId = null, compressed = false, userID = >>>>>> null, >>>>>> content = [EMAIL PROTECTED], >>>>>> marshalledProperties >>>>>> = null, dataStructure = nul >>>>>> l, redeliveryCounter = 0, size = 0, properties = null, >>>>>> readOnlyProperties >>>>>> = >>>>>> false, readOnlyBody = false, droppable = false} >>>>>> [DEBUG] >>>>>> [org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate] >>>>>> Sending created message: ActiveMQObjectMessage {commandId = 0, >>>>>> responseRequired = false, messageId = null >>>>>> , originalDestination = null, originalTransactionId = null, >>>>>> producerId >>>>>> = >>>>>> null, destination = null, transactionId = null, expiration = 0, >>>>>> timestamp >>>>>> = >>>>>> 0, arrival = 0, brokerInTime = >>>>>> 0, brokerOutTime = 0, correlationId = null, replyTo = >>>>>> temp-queue://ID:warc-8a0-3554-1220961055917-0:1:1, persistent = >>>>>> false, >>>>>> type >>>>>> = null, priority = 0, groupID = null, groupSequenc >>>>>> e = 0, targetConsumerId = null, compressed = false, userID = null, >>>>>> content = >>>>>> [EMAIL PROTECTED], marshalledProperties = >>>>>> null, >>>>>> dataStructure = null, redeli >>>>>> veryCounter = 0, size = 0, properties = null, readOnlyProperties = >>>>>> false, >>>>>> readOnlyBody = false, droppable = false} >>>>>> [DEBUG] [org.apache.camel.component.jms.JmsProducer] Future timed >>>>>> out: >>>>>> java.util.concurrent.TimeoutException >>>>>> java.util.concurrent.TimeoutException >>>>>> at >>>>>> java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:211) >>>>>> at java.util.concurrent.FutureTask.get(FutureTask.java:85) >>>>>> at >>>>>> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:202) >>>>>> at >>>>>> org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:43) >>>>>> at >>>>>> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:75) >>>>>> at >>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:146) >>>>>> at >>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:90) >>>>>> at >>>>>> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:39) >>>>>> at >>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:41) >>>>>> at >>>>>> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:66) >>>>>> at >>>>>> org.apache.servicemix.camel.CamelJbiEndpoint.handleActiveProviderExchange(CamelJbiEndpoint.java:101) >>>>>> at >>>>>> org.apache.servicemix.camel.CamelJbiEndpoint.process(CamelJbiEndpoint.java:74) >>>>>> at >>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:540) >>>>>> at >>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:492) >>>>>> at >>>>>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLifeCycle.java:46) >>>>>> at >>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:610) >>>>>> at >>>>>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172) >>>>>> at >>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:167) >>>>>> at >>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134) >>>>>> at >>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) >>>>>> at >>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) >>>>>> at java.lang.Thread.run(Thread.java:595) >>>>>> [ERROR] [org.apache.camel.processor.DeadLetterChannel] Failed >>>>>> delivery >>>>>> for >>>>>> exchangeId: ID-warc-8a0/3556-1220961056058/0-0. On delivery attempt: >>>>>> 0 >>>>>> caught: org.apache.camel.ExchangeT >>>>>> imedOutException: The OUT message was not received within: 20000 >>>>>> millis >>>>>> on >>>>>> the exchange: Exchange[JbiMessage: >>>>>> [EMAIL PROTECTED] >>>>>> erties: {JMSCorrelationID=ID-warc-8a0/3556-1220961056058/2-0}}] >>>>>> org.apache.camel.ExchangeTimedOutException: The OUT message was not >>>>>> received >>>>>> within: 20000 millis on the exchange: Exchange[JbiMessage: >>>>>> org.apache.servicemix.jbi.messaging.Normaliz >>>>>> [EMAIL PROTECTED]: >>>>>> {JMSCorrelationID=ID-warc-8a0/3556-1220961056058/2-0}}] >>>>>> at >>>>>> org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:221) >>>>>> at >>>>>> org.apache.camel.impl.converter.AsyncProcessorTypeConverter$ProcessorToAsyncProcessorBridge.process(AsyncProcessorTypeConverter.java:43) >>>>>> at >>>>>> org.apache.camel.processor.SendProcessor.process(SendProcessor.java:75) >>>>>> at >>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:146) >>>>>> at >>>>>> org.apache.camel.processor.DeadLetterChannel.process(DeadLetterChannel.java:90) >>>>>> at >>>>>> org.apache.camel.processor.UnitOfWorkProcessor.process(UnitOfWorkProcessor.java:39) >>>>>> at >>>>>> org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:41) >>>>>> at >>>>>> org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:66) >>>>>> at >>>>>> org.apache.servicemix.camel.CamelJbiEndpoint.handleActiveProviderExchange(CamelJbiEndpoint.java:101) >>>>>> at >>>>>> org.apache.servicemix.camel.CamelJbiEndpoint.process(CamelJbiEndpoint.java:74) >>>>>> at >>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.doProcess(AsyncBaseLifeCycle.java:540) >>>>>> at >>>>>> org.apache.servicemix.common.AsyncBaseLifeCycle.processExchange(AsyncBaseLifeCycle.java:492) >>>>>> at >>>>>> org.apache.servicemix.common.BaseLifeCycle.onMessageExchange(BaseLifeCycle.java:46) >>>>>> at >>>>>> org.apache.servicemix.jbi.messaging.DeliveryChannelImpl.processInBound(DeliveryChannelImpl.java:610) >>>>>> at >>>>>> org.apache.servicemix.jbi.nmr.flow.AbstractFlow.doRouting(AbstractFlow.java:172) >>>>>> at >>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaFlow.doRouting(SedaFlow.java:167) >>>>>> at >>>>>> org.apache.servicemix.jbi.nmr.flow.seda.SedaQueue$1.run(SedaQueue.java:134) >>>>>> at >>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650) >>>>>> at >>>>>> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675) >>>>>> at java.lang.Thread.run(Thread.java:595) >>>>>> [DEBUG] >>>>>> [org.apache.camel.processor.exceptionpolicy.DefaultExceptionPolicyStrategy] >>>>>> Finding best suited exception policy for thrown exception >>>>>> org.apache.camel.ExchangeTimedOutExcep >>>>>> tion >>>>>> [DEBUG] >>>>>> [org.apache.camel.processor.exceptionpolicy.DefaultExceptionPolicyStrategy] >>>>>> No candidate found to be used as exception policy >>>>>> [DEBUG] [org.apache.camel.processor.DeadLetterChannel] Sleeping for: >>>>>> 1000 >>>>>> millis until attempting redelivery >>>>>> [DEBUG] [org.apache.camel.util.DefaultTimeoutMap] Evicting inactive >>>>>> request >>>>>> for correlationID: Entry for key: null >>>>>> [DEBUG] >>>>>> [org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate] >>>>>> Executing callback on JMS Session: ActiveMQSession >>>>>> {id=ID:warc-8a0-3554-1220961055917-0:3:1,started=false >>>>>> } >>>>>> [DEBUG] [org.apache.camel.component.jms.JmsProducer] >>>>>> Endpoint[jms:queue:foo?priority=0] sending JMS message: >>>>>> ActiveMQObjectMessage {commandId = 0, responseRequired = false, >>>>>> message >>>>>> Id = null, originalDestination = null, originalTransactionId = null, >>>>>> producerId = null, destination = null, transactionId = null, >>>>>> expiration >>>>>> = >>>>>> 0, >>>>>> timestamp = 0, arrival = 0, broker >>>>>> InTime = 0, brokerOutTime = 0, correlationId = null, replyTo = >>>>>> temp-queue://ID:warc-8a0-3554-1220961055917-0:1:1, persistent = >>>>>> false, >>>>>> type >>>>>> = null, priority = 0, groupID = null, gro >>>>>> upSequence = 0, targetConsumerId = null, compressed = false, userID = >>>>>> null, >>>>>> content = [EMAIL PROTECTED], >>>>>> marshalledProperties >>>>>> = null, dataStructure = nul >>>>>> l, redeliveryCounter = 0, size = 0, properties = null, >>>>>> readOnlyProperties >>>>>> = >>>>>> false, readOnlyBody = false, droppable = false} >>>>>> [DEBUG] >>>>>> [org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate] >>>>>> Sending created message: ActiveMQObjectMessage {commandId = 0, >>>>>> responseRequired = false, messageId = null >>>>>> , originalDestination = null, originalTransactionId = null, >>>>>> producerId >>>>>> = >>>>>> null, destination = null, transactionId = null, expiration = 0, >>>>>> timestamp >>>>>> = >>>>>> 0, arrival = 0, brokerInTime = >>>>>> 0, brokerOutTime = 0, correlationId = null, replyTo = >>>>>> temp-queue://ID:warc-8a0-3554-1220961055917-0:1:1, persistent = >>>>>> false, >>>>>> type >>>>>> = null, priority = 0, groupID = null, groupSequenc >>>>>> e = 0, targetConsumerId = null, compressed = false, userID = null, >>>>>> content = >>>>>> [EMAIL PROTECTED], marshalledProperties = >>>>>> null, >>>>>> dataStructure = null, redeli >>>>>> veryCounter = 0, size = 0, properties = null, readOnlyProperties = >>>>>> false, >>>>>> readOnlyBody = false, droppable = false} >>>>>> >>>>>> >>>>>> >>>>>> >>>>> >>>>> >>>> >>>> >>> >>> >> >> > > > ----- Lukasz Dywicki, Integration Developer http://blog.dywicki.pl/ -- View this message in context: http://www.nabble.com/Camel%2C-JBI-%2B-JMS-priority-tp19390754s22882p19604269.html Sent from the Camel - Users mailing list archive at Nabble.com.
