On 26/09/2007, schlemmi <[EMAIL PROTECTED]> wrote: > > Hi, > > First: Camel is very cool, I like that!
Thanks! :) > I used it since 4 weeks with activemq and the lingo library. Great! BTW I've been slowly working on integrating most of the Lingo library functionality now; so you can use Camel to do custom transformations or smart routing, or just use JMS or any other transport just as easily as Lingo... http://activemq.apache.org/camel/bean-integration.html so eventually, when we've got all the features implemented, Camel could be a replacement for Lingo offering more features & being more flexible. > my question: Are message properties not forwarded with Camel ActiveMQ > Component? > > I want to consume a message filtered with message selectors send from a > CamelTemplate > to a comsumer queue. But the message properties wasn't send. So the message > selector doesn't match. > > If I use the direct and bean component I can route with headers. I'am not > sure, if this is a Camel problem > or a ActiveMQ task. > > the log for the send message: > --- > [DEBUG] 26 Sep 2007 13:58:47.229 [ActiveMQ Session Task] > [org.apache.camel.component.jms.JmsConfiguration$2] - 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, correlationId = null, replyTo = null, persistent > = false, type = null, priority = 0, groupID = null, groupSequence = 0, > targetConsumerId = null, compressed = false, userID = null, content = > [EMAIL PROTECTED], marshalledProperties = null, > dataStructure = null, redeliveryCounter = 0, size = 0, properties = > {orderer=helmo}, readOnlyProperties = false, readOnlyBody = false, droppable > = false}] > --- > > the message in the consumer queue: > --- > [INFO] 26 Sep 2007 13:58:47.646 [ActiveMQ Session Task] > [de.planetic.ConsumerTool] - ActiveMQObjectMessage {commandId = 5, > responseRequired = false, messageId = > ID:merope-42394-1190807879122-1:2:1:1:1, originalDestination = null, > originalTransactionId = null, producerId = > ID:merope-42394-1190807879122-1:2:1:1, destination = > queue://servicefacade.return, transactionId = null, expiration = 0, > timestamp = 1190807927230, arrival = 0, correlationId = null, replyTo = > null, persistent = false, type = null, priority = 0, groupID = null, > groupSequence = 0, targetConsumerId = null, compressed = false, userID = > null, content = [EMAIL PROTECTED], > marshalledProperties = [EMAIL PROTECTED], > dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, > readOnlyProperties = true, readOnlyBody = true, droppable = false} > > --- > Please look at the properties. There are not forwarded to the customer > queue. Are you positive thats not just a logging issue. (ActiveMQ only deserializes the properties lazily; so they don't necessarily always appear in a log statement AFAIK). > The route: > > from("direct:de.planetic.renderfacade"). > filter(body().isInstanceOf(RenderReturnMessage.class)). > to("activemq:servicefacade.return?preserveMessageQos=true"); > > --- > my setup: I am using Camel 1.1 and the new Camel-1.1.20070926.001132-62 > snapshot ( without activemq component?) and ApacheActiveMQ 4.1.1 with Java > 1.5 (build 1.5.0_08-b03) and a Linux Box with > 2.6.16.21 Kernel FWIW there have been some issues post 1.1 with preserving headers with JMS but AFAIK they are all fixed now? I wonder any chance you could create a little JUnit test case to show your issue? AFAIK headers should be preserved. -- James ------- http://macstrac.blogspot.com/ Open Source SOA http://open.iona.com
