Oh, live and learn.
It works great now, thanks!
--
Kalle
----- Original Message -----
From: "Gordon Sim" <[email protected]>
To: <[email protected]>
Sent: Thursday, March 19, 2009 2:01 PM
Subject: Re: ReplyTo header
Kalle Kärkkäinen wrote:
I use direct queues and try to get replyto's working. I'm sending plain
messages with routing keys with ease, but when tagging messages like
this:
session.messageTransfer( "exchange",
MessageAcceptMode.EXPLICIT,
MessageAcquireMode.PRE_ACQUIRED,
new Header(new DeliveryProperties().setRoutingKey("queue1"), new
ReplyTo("exchange", "queue2")), msg);
I think that should be:
session.messageTransfer( "exchange",
MessageAcceptMode.EXPLICIT,
MessageAcquireMode.PRE_ACQUIRED,
new Header(
new DeliveryProperties().setRoutingKey("queue1"),
new MessageProperties().setReplyTo(new ReplyTo("exchange", "queue2")),
msg);
The two key structs types that are supported in the header are
delivery-properties and message-properties. The reply-to struct is a field
of message-properties.
So basically I've got one exchange, with queue1 and queue2. I'm trying to
send message to queue1, with replyto to queue2, so that my other process
will get a response.
It seems that implementation to both DeliveryProperties and ReplyTo are
missing. I've got them from commons-M4 jar, but in common project there
is no sign of them.
Those classes are generated from the AMQP spec file and are place in the
build directory for compilation. E.g.
build/common/src/org/apache/qpid/transport/ReplyTo.java
--Gordon.
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
