I am using camel 2.10.3 version
On Sep 5, 2013 10:22 PM, "Prabu" <prabumc...@gmail.com> wrote:
> Pls help me...
>
> *Thanks*
> Prabu.N
>
>
> On Thu, Sep 5, 2013 at 6:41 PM, Prabu <prabumc...@gmail.com> wrote:
>
>> Hi Ceposta,
>>
>> After enable debug i can see following log details.
>>
>> 2013-09-05 08:02:41,023 | DEBUG |
>> Endpoint[activemq://queue:BOA.InboundQueue] consumer received JMS message:
>> ActiveMQTextMessage {commandId = 24, responseRequired = true, messageId =
>> ID:Corp-TSOpus02-50552-1378385398624-4:1:1:1:20, originalDestination =
>> null, originalTransactionId = null, producerId =
>> ID:Corp-TSOpus02-50552-1378385398624-4:1:1:1, destination =
>> queue://BOA.InboundQueue, transactionId = null, expiration = 0, timestamp =
>> 1378386161018, arrival = 0, brokerInTime = 1378386161020, brokerOutTime =
>> 1378386161022, correlationId = null, replyTo = null, persistent = true,
>> type = null, priority = 4, groupID = null, groupSequence = 0,
>> targetConsumerId = null, compressed = false, userID = null, content = null,
>> marshalledProperties = org.apache.activemq.util.ByteSequence@58b94e98,
>> dataStructure = null, redeliveryCounter = 0, size = 1539, properties =
>> {MESSAGE_ID=cde10e13-5e66-4dac-88bd-acc05aa091e8, PAST_EVENT_INTERVAL=0,
>> MEMOS_TARGET_SERVERS=PITB-MW-MSG0A01:PITB-MW-MSG0A02,
>> soft_EVENT_CLASS_NAME=com.soft.event.TestEvent, soft_EVENT_VERSION=1,
>> RESTFUL_SERVICE_URL=http://Corp-TSOpus02:5050/memos/,
>> EXPIRY_TIME=300000, TestEventType=LogMessage,
>> soft_EVENT_TYPE=Memos.Consumer.Test}, readOnlyProperties = true,
>> readOnlyBody = true, droppable = false, text = {"creationDate":"Sep 05,
>> 2013 8:02:41 AM","na...nterval":0}
>> } | org.apache.camel.component.jms.EndpointMessageListener | Camel
>> (camelContext1) thread #0 - JmsConsumer[BOA.InboundQueue]
>> 2013-09-05 08:02:41,024 | DEBUG | #0 - header{header(soft_EVENT_TYPE)} is
>> not null matches: true for: Exchange[JmsMessage[JmsMessageID:
>> ID:Corp-TSOpus02-50552-1378385398624-4:1:1:1:20]] |
>> org.apache.camel.processor.ChoiceProcessor | Camel (camelContext1) thread
>> #0 - JmsConsumer[BOA.InboundQueue]
>>
>> 2013-09-05 08:02:41,025 | DEBUG | Redelivery enabled: false on error
>> handler:
>> DefaultErrorHandler[Producer[activemq://queue:Inbound.Memos.Consumer.Test]]
>> | org.apache.camel.processor.DefaultErrorHandler | Camel (camelContext1)
>> thread #0 - JmsConsumer[BOA.InboundQueue]
>> 2013-09-05 08:02:41,025 | DEBUG | Executing callback on JMS Session:
>> Cached JMS Session: ActiveMQSession
>> {id=ID:pitb-mw-msg0a02.test.aus.soft.net-3432-1378385347963-3:1:30,started=true}
>> | org.apache.camel.component.jms.JmsConfiguration$CamelJmsTemplate | Camel
>> (camelContext1) thread #0 - JmsConsumer[BOA.InboundQueue]
>>
>> 2013-09-05 08:02:41,026 | DEBUG | Sending JMS message to:
>> queue://Inbound.Memos.Consumer.Test with message: ActiveMQTextMessage
>> {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 = null, persistent = true, type = null, priority = 4, groupID =
>> null, groupSequence = 0, targetConsumerId = null, compressed = false,
>> userID = null, content = null, marshalledProperties = null, dataStructure =
>> null, redeliveryCounter = 0, size = 0, properties =
>> {MESSAGE_ID=cde10e13-5e66-4dac-88bd-acc05aa091e8, PAST_EVENT_INTERVAL=0,
>> MEMOS_TARGET_SERVERS=PITB-MW-MSG0A01:PITB-MW-MSG0A02,
>> soft_EVENT_CLASS_NAME=com.soft.event.TestEvent, soft_EVENT_VERSION=1,
>> breadcrumbId=ID:Corp-TSOpus02-50552-1378385398624-4:1:1:1:20,
>> RESTFUL_SERVICE_URL=http://Corp-TSOpus02:5050/memos/,
>> EXPIRY_TIME=300000, CamelJmsDeliveryMode=2, TestEventType=LogMessage,
>> soft_EVENT_TYPE=Memos.Consumer.Test}, readOnlyProperties = false,
>> readOnlyBody = false, droppable = false, text = {"creationDate":"Sep 05,
>> 2013 8:02:41 AM","na...nterval":0}
>>
>>
>> *Thanks*
>> Prabu.N
>>
>>
>>
>> On Thu, Sep 5, 2013 at 11:36 AM, Prabu <prabumc...@gmail.com> wrote:
>>
>>> *Queue name*
>>>
>>> public static final String CONSUMER_TEST_QNAME =
>>> "activemq:queue:ConsumerTestHandlerjmsMessageType=Text&preserveMessageQos=true";
>>>
>>> public static final String PRODUCER_TEST_QNAME =
>>> "activemq:queue:ProducerTestHandler?jmsMessageType=Text&preserveMessageQos=true";
>>>
>>> public static final String MESSAGING_TEST_CONSUMER_TYPE_SPECIFIC_QNAME
>>> = "activemq:queue:Inbound.Memos.Consumer.Test";
>>>
>>> public static final String MESSAGING_TEST_PRODUCER_TYPE_SPECIFIC_QNAME
>>> = "activemq:queue:Inbound.Memos.Producer.Test";
>>>
>>> Sorry,I am new to camel.So i am sure what your asking.
>>>
>>> *Thanks*
>>> Prabu.N
>>>
>>>
>>>
>>> On Thu, Sep 5, 2013 at 9:49 AM, ceposta [via Camel] <
>>> ml-node+s465427n573871...@n5.nabble.com> wrote:
>>>
>>>> Maybe a good idea to go through my previous questions closely and
>>>> provide
>>>> answers so we can better help you:
>>>>
>>>> "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 9:09 PM, [hidden
>>>> email]<http://user/SendEmail.jtp?type=node&node=5738713&i=0>
>>>> <[hidden email]
>>>> <http://user/SendEmail.jtp?type=node&node=5738713&i=1>>wrote:
>>>>
>>>>
>>>> > Yes I can some messages in dlq.type.specfic.queue and some messgaes
>>>> on type
>>>> > specific queue.
>>>> >
>>>> > Messges not route to outbound queue.
>>>> >
>>>> > Pls suggest what is the fix for this.
>>>> >
>>>> > It almost 2 days I am having this issue pls suggest
>>>> > On Sep 5, 2013 8:17 AM, "ceposta [via Camel]" <
>>>> > [hidden email] <http://user/SendEmail.jtp?type=node&node=5738713&i=2>>
>>>> wrote:
>>>> >
>>>> > > Maybe your TTL is set too short and the broker is rejecting those
>>>> > > messages.
>>>> > > Can you check your DLQ to see whether the messages are in there?
>>>> > >
>>>> > >
>>>> > > On Wed, Sep 4, 2013 at 7:07 PM, [hidden email]<
>>>> > http://user/SendEmail.jtp?type=node&node=5738709&i=0>
>>>> > > <[hidden email] <
>>>> http://user/SendEmail.jtp?type=node&node=5738709&i=1
>>>>
>>>> > >>wrote:
>>>> > >
>>>> > >
>>>> > > > I am using simple failover url
>>>> > > >
>>>> > > > Failover:(ssl://br1,ssl://br2)
>>>> > > >
>>>> > > > my aim is set expiry time to message thats why I am
>>>> producertemplate it
>>>> > > > creating issue here.
>>>> > > >
>>>> > > > Message will send
>>>> > > >
>>>> > > > Type specific queue After that camel use producertemplate set
>>>> expiry
>>>> > > time
>>>> > > > to msg it send msg to another outbound queue.
>>>> > > >
>>>> > > > Now what is happening message staying on type specific queue and
>>>> it
>>>> > > routing
>>>> > > > message each 3 to 5 min time.taking long time to route msg.
>>>> > > >
>>>> > > > Pls kindly help me.
>>>> > > > On Sep 5, 2013 1:42 AM, "ceposta [via Camel]" <
>>>> > > > [hidden email] <
>>>> http://user/SendEmail.jtp?type=node&node=5738709&i=2>>
>>>> > > wrote:
>>>> > > >
>>>> > > > > 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, [hidden email]<
>>>> > > > http://user/SendEmail.jtp?type=node&node=5738702&i=0>
>>>> > > > > <[hidden email] <
>>>> > http://user/SendEmail.jtp?type=node&node=5738702&i=1
>>>> > > > >>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 {
>>>> > > > > > private static final Logger LOG =
>>>> > > > > > LoggerFactory.getLogger(MemosProcess.class);
>>>> > > > > >
>>>> > > > > > ProducerTemplate prodtemplate=null;
>>>> > > > > > public MemosProcess(){
>>>> > > > > >
>>>> > > > > > }
>>>> > > > > > public MemosProcess(ProducerTemplate template) {
>>>> > > > > > this.prodtemplate=template;
>>>> > > > > > }
>>>> > > > > >
>>>> > > > > > @Override
>>>> > > > > > public void process(Exchange exchange) throws Exception
>>>> {
>>>> > > > > > JmsMessage msg = (JmsMessage) exchange.getIn();
>>>> > > > > > Map<String, Object> headers = msg.getHeaders();
>>>> > > > > >
>>>> > > > > > String eventType = (String)
>>>> > > > > headers.get(EVENT_TYPE);
>>>> > > > > > String msgId = (String)
>>>> > > > > headers.get(MESSAGE_ID);
>>>> > > > > > System.out.println("Memos-msgid:"+msgId);
>>>> > > > > > int msg_Expiry_Time =
>>>> Integer.parseInt((String)
>>>> > > > > > headers.get(EXPIRY_TIME));
>>>> > > > > > InetAddress address =
>>>> InetAddress.getLocalHost();
>>>> > > > > > String hostname =
>>>> address.getHostName();
>>>> > > > > > long MSG_EXPIRY = System.currentTimeMillis() +
>>>> > > > > msg_Expiry_Time;
>>>> > > > > > headers.put(JMSExpiration,MSG_EXPIRY);
>>>> > > > > >
>>>> > > > > > String restfulServiceURL =(String)
>>>> > > > > > headers.get(MEMOS_RESTFULSERVICE_URL);
>>>> > > > > > restfulServiceURL=restfulServiceURL+"update";
>>>> > > > > >
>>>> > > > > > if
>>>> (eventType.equalsIgnoreCase(CONSUMER_EVENT_TYPE)) {
>>>> > > > > >
>>>> > > > > > String serversList = (String)
>>>> > > > > > headers.get(MEMOS_TARGET_SERVERS);
>>>> > > > > >
>>>> > > > > > String servers [] = serversList.split(":");
>>>> > > > > > String handler1 = "";
>>>> > > > > > String handler2 = "";
>>>> > > > > >
>>>> > > > > > if (servers.length >=2) {
>>>> > > > > > handler1 = servers[0];
>>>> > > > > > handler2 = servers[1];
>>>> > > > > > }
>>>> > > > > > headers.put(MEMOS_TARGET_SERVER,handler1);
>>>> > > > > >
>>>> > > > > prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,"Consumer
>>>> > > > > > test",headers);
>>>> > > > > > headers.put(MEMOS_TARGET_SERVER,handler2);
>>>> > > > > > new MemosProcess().callService(msgId,
>>>> > > > > > hostname,restfulServiceURL);
>>>> > > > > >
>>>> > > > > prodtemplate.sendBodyAndHeaders(CONSUMER_TEST_QNAME,"Consumer
>>>> > > > > > test",headers);
>>>> > > > > > }else
>>>> > if(eventType.equalsIgnoreCase(PRODUCER_EVENT_TYPE)){
>>>> > > > > > new MemosProcess().callService(msgId,
>>>> > > > > > hostname,restfulServiceURL);
>>>> > > > > >
>>>> > > > > prodtemplate.sendBodyAndHeaders(PRODUCER_TEST_QNAME,"Producer
>>>> > > > > > test",headers);
>>>> > > > > > }
>>>> > > > > > }
>>>> > > > > >
>>>> > > > > >
>>>> > > > > > 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.
>>>> > > > > >
>>>> > > > > > Please kindly help me.
>>>> > > > > >
>>>> > > > > >
>>>> > > > > >
>>>> > > > > > --
>>>> > > > > > View 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.christianposta.com/blog
>>>> > > > >
>>>> > > > >
>>>> > > > > ------------------------------
>>>> > > > > If you reply to this email, your message will be added to the
>>>> > > discussion
>>>> > > > > below:
>>>> > > > >
>>>> > > > >
>>>> > > >
>>>> > >
>>>> >
>>>> http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738702.html
>>>> > > > > To unsubscribe from Camel routing issue after upgrade into
>>>> active-mq
>>>> > > > 5.8, click
>>>> > > > > here<
>>>> > > > >
>>>> > > > > .
>>>> > > > > NAML<
>>>> > > >
>>>> > >
>>>> >
>>>> http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml
>>>> > > > >
>>>> > > > >
>>>> > > >
>>>> > > >
>>>> > > >
>>>> > > >
>>>> > > > --
>>>> > > > View this message in context:
>>>> > > >
>>>> > >
>>>> >
>>>> http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738708.html
>>>> > > > Sent from the Camel - Users mailing list archive at Nabble.com.
>>>> > > >
>>>> > >
>>>> > >
>>>> > >
>>>> > > --
>>>> > > *Christian Posta*
>>>> > > http://www.christianposta.com/blog
>>>> > > twitter: @christianposta
>>>> > > http://www.christianposta.com/blog
>>>> > >
>>>> > >
>>>> > > ------------------------------
>>>> > > If you reply to this email, your message will be added to the
>>>> discussion
>>>> > > below:
>>>> > >
>>>> > >
>>>> >
>>>> http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738709.html
>>>> > > To unsubscribe from Camel routing issue after upgrade into
>>>> active-mq
>>>> > 5.8, click
>>>> > > here<
>>>> > >
>>>> > > .
>>>> > > NAML<
>>>> >
>>>> http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml
>>>> > >
>>>> > >
>>>> >
>>>> >
>>>> >
>>>> >
>>>> > --
>>>> > View this message in context:
>>>> >
>>>> http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738712.html
>>>>
>>>> > Sent from the Camel - Users mailing list archive at Nabble.com.
>>>> >
>>>>
>>>>
>>>>
>>>> --
>>>> *Christian Posta*
>>>> http://www.christianposta.com/blog
>>>> twitter: @christianposta
>>>> http://www.christianposta.com/blog
>>>>
>>>>
>>>> ------------------------------
>>>> If you reply to this email, your message will be added to the
>>>> discussion below:
>>>>
>>>> http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738713.html
>>>> To unsubscribe from Camel routing issue after upgrade into active-mq
>>>> 5.8, click
>>>> here<http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=unsubscribe_by_code&node=5738700&code=cHJhYnVtY2EwNkBnbWFpbC5jb218NTczODcwMHw4OTY0MTU3ODg=>
>>>> .
>>>> NAML<http://camel.465427.n5.nabble.com/template/NamlServlet.jtp?macro=macro_viewer&id=instant_html%21nabble%3Aemail.naml&base=nabble.naml.namespaces.BasicNamespace-nabble.view.web.template.NabbleNamespace-nabble.view.web.template.NodeNamespace&breadcrumbs=notify_subscribers%21nabble%3Aemail.naml-instant_emails%21nabble%3Aemail.naml-send_instant_email%21nabble%3Aemail.naml>
>>>>
>>>
>>>
>>>
>>> --
>>> Thanks & Regards
>>> Prabu.N
>>>
>>
>>
>>
>> --
>> Thanks & Regards
>> Prabu.N
>>
>
>
>
> --
> Thanks & Regards
> Prabu.N
>
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738804.html
Sent from the Camel - Users mailing list archive at Nabble.com.
