Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (athena.apache.org: domain of cmoulliard@gmail.com
 designates 74.125.82.173 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type;
        b=GRUQ+I4oFfLVHLxMcswg0cLvml0y4AcTNJTQST4PUVnKo6verHmWDFgCjrRUxMjSFU
         19CMTg6tHaFWLUmb3pGM+D1NYxMfXHH8Cem+PeAoMirM5q89F9AuwrYYxAL39msOGssa
         S4RMaUiDIgDfrztKR4ZCe7tRldjBGB398Cfow=
MIME-Version: 1.0
In-Reply-To: <5380c69c1003120119i70a5319cv2a0ed40a8439de8d@mail.gmail.com>
References: <a364c40b1003110543w3c737cd5rca5a83936f82e721@mail.gmail.com>
	 <4B99F47C.9090309@gmail.com>
	 <a364c40b1003120107t7b7707dej65b40daeb7019d09@mail.gmail.com>
	 <5380c69c1003120119i70a5319cv2a0ed40a8439de8d@mail.gmail.com>
Date: Fri, 12 Mar 2010 10:41:51 +0100
Message-ID: <a364c40b1003120141k51b36f8dpe896aeae5f2afe38@mail.gmail.com>
Subject: Re: ActiveMQ Advisory Message and Camel (no type converter available)
From: Charles Moulliard <cmoulliard@gmail.com>
To: users@camel.apache.org
Content-Type: multipart/alternative; boundary=0016e65426364d8dd2048197579c

--0016e65426364d8dd2048197579c
Content-Type: text/plain; charset=ISO-8859-1

Yep. I will continue tests this afternoon to be sure that we receive in the
messages what is supposed to be there ;-) and report info on the wiki page

Kind regards,

Charles Moulliard
Senior Enterprise Architect
Apache Camel Committer

*****************************
blog : http://cmoulliard.blogspot.com
twitter : http://twitter.com/cmoulliard
Linkedlin : http://www.linkedin.com/in/charlesmoulliard

Apache Camel Group :
http://www.linkedin.com/groups?home=&gid=2447439&trk=anet_ug_hm


On Fri, Mar 12, 2010 at 10:19 AM, Claus Ibsen <claus.ibsen@gmail.com> wrote:

> On Fri, Mar 12, 2010 at 10:07 AM, Charles Moulliard
> <cmoulliard@gmail.com> wrote:
> > Hi Willem,
> >
> > Thanks for the info. IT works fine now with what you suggest :
> >
>
> Charles can you add a section on the ActiveMQ component how to use
> advisory messages with Camel?
> http://camel.apache.org/activemq.html
>
> Basically what you did to get it working.
>
>
>
> > 10:06:18,328 | INFO  | tenerContainer-1 | elca
>   |
> > rg.apache.camel.processor.Logger   88 | Exchange[
> > , Id:ID:dell-charles-1395-1268384347390-3:0:0:0:12
> > ,
> Properties:{CamelBinding=org.apache.camel.component.jms.JmsBinding@1d75e80
> ,
> > CamelToEndpoint=log://com.elca?multiline=true&showAll=true}
> > , Headers:{originBrokerURL=vm://master, JMSType=Advisory,
> > originBrokerId=ID:dell-charles-1395-1268384347390-2:0, JMSDeliveryMode=1,
> > JMSDestination=top
> > ic://ActiveMQ.Advisory.Connection, JMSRedelivered=false,
> JMSXGroupID=null,
> > JMSMessageID=ID:dell-charles-1395-1268384347390-3:0:0:0:12,
> JMSReplyTo=null
> > , JMSExpiration=0, JMSTimestamp=0, JMSCorrelationID=null,
> > originBrokerName=master, JMSPriority=0}
> > , BodyType:org.apache.activemq.command.ActiveMQMessage
> > , Body:ActiveMQMessage {commandId = 0, responseRequired = false,
> messageId =
> > ID:dell-charles-1395-1268384347390-3:0:0:0:12, originalDestination = null
> > , originalTransactionId = null, producerId =
> > ID:dell-charles-1395-1268384347390-3:0:0:0, destination =
> > topic://ActiveMQ.Advisory.Connection, transacti
> > onId = null, expiration = 0, timestamp = 0, arrival = 0, brokerInTime =
> > 1268384778312, brokerOutTime = 1268384778312, correlationId = null,
> replyTo
> > =
> > null, persistent = false, type = Advisory, priority = 0, groupID = null,
> > groupSequence = 0, targetConsumerId = null, compressed = false, userID =
> > null
> > , content = null, marshalledProperties =
> > org.apache.activemq.util.ByteSequence@145240a, dataStructure =
> > ConnectionInfo {commandId = 1, responseRequire
> > d = true, connectionId = ID:dell-charles-1408-1268384777218-0:0, clientId
> =
> > ID:dell-charles-1408-1268384777218-1:0, userName = , password = *****,
> bro
> > kerPath = null, brokerMasterConnector = false, manageable = true,
> > clientMaster = true}, redeliveryCounter = 0, size = 0, properties =
> > {originBrokerNam
> > e=master, originBrokerId=ID:dell-charles-1395-1268384347390-2:0,
> > originBrokerURL=vm://master}, readOnlyProperties = true, readOnlyBody =
> > true, droppab
> > le = false}
> > , Out: null]
> >
> > Kind regards,
> >
> > Charles Moulliard
> > Senior Enterprise Architect
> > Apache Camel Committer
> >
> > *****************************
> > blog : http://cmoulliard.blogspot.com
> > twitter : http://twitter.com/cmoulliard
> > Linkedlin : http://www.linkedin.com/in/charlesmoulliard
> >
> > Apache Camel Group :
> > http://www.linkedin.com/groups?home=&gid=2447439&trk=anet_ug_hm
> >
> >
> > On Fri, Mar 12, 2010 at 8:59 AM, Willem Jiang <willem.jiang@gmail.com
> >wrote:
> >
> >> Hi Charles,
> >>
> >> Can you try to set the activemq endpoint's URI with mapJmsMessage=false
> >> option?
> >> As camel-jms will try to extract the message body into its known type,
> and
> >> I don't think it support ActiveMQMessage out of box.
> >> With mapJmsMessage=false, the message body will be set with the
> JMSMessage
> >> that camel-jms get from MS queue.
> >>
> >> Willem
> >>
> >>
> >>
> >> Charles Moulliard wrote:
> >>
> >>> Hi,
> >>>
> >>> I try to read messages published in a topic of ActiveMq -->
> >>> ActiveMQ.Advisory.* but get a type error converter has the body is null
> >>>
> >>>        <camel:route>
> >>>            <camel:from    uri="activemq:topic:ActiveMQ.Advisory.*" />
> >>>            <camel:convertBodyTo
> >>> type="org.apache.activemq.command.ActiveMQMessage"/>
> >>>            <camel:to uri="log:com.elca?showAll=true&amp;multiline=true"
> />
> >>>        </camel:route>
> >>>
> >>> How can I avoid this error ?
> >>>
> >>> Causedby: No type converter available to convert from type: null to the
> >>> required type: org.apache.activemq.command.ActiveMQMessage with value
> >>> null.
> >>> Exchange
> >>> [JmsMessage: ActiveMQMessage {commandId = 0, responseRequired = false,
> >>> messageId = ID:dell-charles-2709-1268314715843-1:0:0:0:8,
> >>> originalDestination =
> >>>  null, originalTransactionId = null, producerId =
> >>> ID:dell-charles-2709-1268314715843-1:0:0:0, destination =
> >>> topic://ActiveMQ.Advisory.Connection, tran
> >>> sactionId = null, expiration = 0, timestamp = 0, arrival = 0,
> brokerInTime
> >>> =
> >>> 1268314769343, brokerOutTime = 1268314769343, correlationId = null,
> reply
> >>> To = null, persistent = false, type = Advisory, priority = 0, groupID =
> >>> null, groupSequence = 0, targetConsumerId = null, compressed = false,
> >>> userID
> >>> =
> >>>  null, content = null, marshalledProperties =
> >>> org.apache.activemq.util.ByteSequence@97e111, dataStructure =
> RemoveInfo
> >>> {commandId = 0, responseRequire
> >>> d = true, objectId = ID:dell-charles-2711-1268314762093-0:0,
> >>> lastDeliveredSequenceId = 0}, redeliveryCounter = 0, size = 0,
> properties
> >>> =
> >>> {originBroker
> >>> Name=master, originBrokerId=ID:dell-charles-2709-1268314715843-0:0,
> >>> originBrokerURL=vm://master}, readOnlyProperties = true, readOnlyBody =
> >>> true, drop
> >>> pable = false}]. Caused by:
> >>> [org.apache.camel.NoTypeConversionAvailableException - No type
> converter
> >>> available to convert from type: null to the requi
> >>> red type: org.apache.activemq.command.ActiveMQMessage with value null]
> >>>        at
> >>>
> >>>
> org.apache.camel.impl.MessageSupport.getMandatoryBody(MessageSupport.java:103)
> >>>        at
> >>>
> >>>
> org.apache.camel.processor.ConvertBodyProcessor.process(ConvertBodyProcessor.java:55)
> >>>        at
> >>>
> >>>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
> >>>        at
> >>>
> >>>
> org.apache.camel.processor.DelegateProcessor.processNext(DelegateProcessor.java:53)
> >>>        at
> >>>
> >>>
> org.apache.camel.processor.DelegateProcessor.proceed(DelegateProcessor.java:82)
> >>>        at
> >>>
> >>>
> org.apache.camel.processor.interceptor.TraceInterceptor.process(TraceInterceptor.java:161)
> >>>        at
> >>>
> >>>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
> >>>        at
> >>>
> >>>
> org.apache.camel.processor.RedeliveryErrorHandler.processExchange(RedeliveryErrorHandler.java:177)
> >>>        at
> >>>
> >>>
> org.apache.camel.processor.RedeliveryErrorHandler.processErrorHandler(RedeliveryErrorHandler.java:143)
> >>>        at
> >>>
> >>>
> org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:88)
> >>>        at
> >>>
> >>>
> org.apache.camel.processor.DefaultErrorHandler.process(DefaultErrorHandler.java:49)
> >>>        at
> >>>
> org.apache.camel.processor.DefaultChannel.process(DefaultChannel.java:228)
> >>>        at org.apache.camel.processor.Pipeline.process(Pipeline.java:74)
> >>>        at
> >>>
> >>>
> org.apache.camel.processor.UnitOfWorkProcessor.processNext(UnitOfWorkProcessor.java:66)
> >>>        at
> >>>
> >>>
> org.apache.camel.processor.DelegateProcessor.process(DelegateProcessor.java:48)
> >>>        at
> >>>
> >>>
> org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:67)
> >>>        at
> >>>
> >>>
> org.apache.camel.component.jms.EndpointMessageListener.onMessage(EndpointMessageListener.java:84)
> >>>        ... 9 more
> >>>
> >>> Kind regards,
> >>>
> >>> Charles Moulliard
> >>> Senior Enterprise Architect
> >>> Apache Camel Committer
> >>>
> >>> *****************************
> >>> blog : http://cmoulliard.blogspot.com
> >>> twitter : http://twitter.com/cmoulliard
> >>> Linkedlin : http://www.linkedin.com/in/charlesmoulliard
> >>>
> >>> Apache Camel Group :
> >>> http://www.linkedin.com/groups?home=&gid=2447439&trk=anet_ug_hm
> >>>
> >>>
> >>
> >
>
>
>
> --
> 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
>

--0016e65426364d8dd2048197579c--