Beta 1 packages have been created, so you can try those if you want.
hopefully 0.6 will be out in a few
weeks
Carl.
Brant Boehmann wrote:
Is there an estimated release date for 0.6?
On Tue, Dec 15, 2009 at 8:42 AM, Robbie Gemmell <[email protected]>wrote:
Hi Brant,
You appear to have run into this issue:
https://issues.apache.org/jira/browse/QPID-2242
It has been resolved on trunk, and so will go out in the upcoming 0.6
release.
Robbie
-----Original Message-----
From: Brant Boehmann [mailto:[email protected]]
Sent: 15 December 2009 13:23
To: [email protected]
Subject: getJMSDestimation
I'm trying to utilize the qpid java client using only JMS classes (not
AMQP
or QPID classes). However the Message.getJMSDestination() always
returns
null. Note I'm using the C++ broker.
I am subscribing to messages like so:
Topic topic = _session.createTopic("#");
TopicSubscriber messageSubscriber = _session.createSubscriber(topic);
messageSubscriber.setMessageListener(new MyMessageListener());
So my listener is receiving messages from multiple topics. When that
message
is received, I'd like to know what topic it was sent to.
Here's what I'm trying:
public void onMessage(Message message) {
try {
BytesMessage bytes = (BytesMessage) message;
String routingKey = null;
Topic topic = (Topic)message.getJMSDestination();
if(topic != null) {
routingKey = topic.getTopicName();
}
System.out.println("Routing Key: " + routingKey);
} catch(JMSException ex) {
ex.printStackTrace();
}
}
Unfortunately, message.getJMSDestination() always returns null for me.
I can get it to work this way, but again I don't want to tie my code to
qpid
specific classes:
public void onMessage(Message message) {
JMSBytesMessage qpidbytes = (JMSBytesMessage) message;
AMQMessageDelegate_0_10 delegate = (AMQMessageDelegate_0_10)
qpidbytes.getDelegate();
String routingKey = delegate.getDeliveryProperties().getRoutingKey();
System.out.println("Routing Key: " + routingKey);
}
I even tried explicitly setting the JMSDestination when publishing the
message, but that doesn't seem to make any difference. Why does
getJMSDestination() always return null? Is there a workaround for me?
Thanks in advance
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
