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
--
View this message in context:
http://camel.465427.n5.nabble.com/Camel-routing-issue-after-upgrade-into-active-mq-5-8-tp5738700p5738763.html
Sent from the Camel - Users mailing list archive at Nabble.com.
