ive 5.5 but after upgrade into
active
5.8
it
is
not working
Message getting hang in
MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME
not
calling memosprocess class.
Please kindly help me.
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-in
;>String eventType= (String)
> >>>>>>>>> headers.get(EVENT_TYPE);
> >>>>>>>>>> String msgId= (String)
> >>>>>>>>> headers.get(MESSAGE_ID);
> >>>
this message in context:
http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700.html
Sent from the Camel - Users mailing list archive at
Nabble.com.
--
*Christian Posta*
http://www.christianposta.com/blog
twitter: @christianposta
http://www.christ
MESSAGE_ID);
>>>> > > > > > System.out.println("Memos-msgid:"+msgId);
>>>> > > > > > int msg_Expiry_Time =
>>>> Integer.parseInt((String)
>>>> > > > > > headers.get(E
SExpiration,MSG_EXPIRY);
>>> > > > > >
>>> > > > > > String restfulServiceURL =(String)
>>> > > > > > headers.get(MEMOS_RESTFULSERVICE_URL);
>>> > > > > > restfulServiceURL=restful
t; String serversList= (String)
>> > > > > > headers.get(MEMOS_TARGET_SERVERS);
>> > > > > >
>> > > > > > String servers [] = serversList.split(":");
>> > > > > >
= servers[0];
> > > > > > handler2 = servers[1];
> > > > > > }
> > > > > > headers.put(MEMOS_TARGET_SERVER,handler1);
> > > > > >
> > > > > prodtemplate.sendBodyAndHea
> new MemosProcess().callService(msgId,
> > > > > hostname,restfulServiceURL);
> > > > >
> > > > prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,"Consumer
> > > > > test",headers);
> > > > >
late.sendBodyAndHeaders(CONSUMER_TEST_QNAME,"Consumer
> > > > test",headers);
> > > > }else if(eventType.equalsIgnoreCase(PRODUCER_EVENT_TYPE)){
> > > > new MemosProcess().callService(msgId,
> > > > hostname,restfulService
> above code worked fine in active 5.5 but after upgrade into active 5.8
> > it
> > > is
> > > not working
> > >
> > > Message getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not
> > > calling memosprocess class.
> > >
&g
getting hang in MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME not
> > calling memosprocess class.
> >
> > Please kindly help me.
> >
> >
> >
> > --
> > View this message in context:
> >
> http://camel.465427.n5
What does it do? Does the broker dispatch messages to the client (you can
see with the "in-flight" metrics on the broker)? Can you turn up the
logging and see what camel is doing? what sort of ack mode are you using on
the connection?
On Wed, Sep 4, 2013 at 11:50 AM, prabumc...@gmail.com
wrote:
My code worked fine in activemq 5.5 only issue after upgrading activemq 5.8
Camel i having code like
from(MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME).process(new
MemosProcess(getContext().createProducerTemplate()))
.end();
class MemosProcess implements Processor,QnamesInterface {
pri
13 matches
Mail list logo
