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]
