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
