Sorry, had a bit of premature posting there. :) Second try, now trying to
suppress control-enter.
Hi all,
I'm piecing together something and ran into a little bit of trouble.
I'm using the raw-amqp in java with 0-10; with
org.apache.qpid.transport.Connection and Session. It's working well with the
cpp broker, no worries there.
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);
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.
I get this UnsupportedOperation stack from Struct as it is defaulting to
that method in getEncodedType. I'm I using too cutting edge here?
I'm using this raw'ish interface because it seems simpler and more intuitive
than JMS, also should contain all the power of AMQP (I guess).
--
Kalle
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
