Hi Sanjeev,
In Java it's all in JMS, you've got a couple of options - one is to
create a queue "administratively" via qpid-config
e.g. qpid-config add queue testqueue --limit-policy=ring
Or you could do it via an address, the following is for a queue called
testqueue, bound to the default headers exchange matching a couple of
headers with a size of 500MB
testqueue; {create: receiver, node: {x-declare: {arguments:
{'qpid.policy_type': ring, 'qpid.max_size': 500000000}}, x-bindings:
[{exchange: 'amq.match', queue: 'testqueue', key: 'data1', arguments:
{x-match: all, data-service: amqp-delivery, item-owner: fadams}}]}}
The x-bindings will clearly be different if you use a different exchange
(or if you want to match different headers :-)) hopefully this gives you
the idea. Take a look at the "Address" section in the "Programming in
Apache Qpid" book and hopefully you'll see the pattern.
HTH
Frase
sspandit wrote:
Looking for example of using (create, publish, consume, delete) ring queue
using Java.
Thanks in advance.
Sanjeev
--
View this message in context:
http://apache-qpid-users.2158936.n2.nabble.com/How-to-use-Qpid-Ring-Queues-in-Java-tp7028249p7028249.html
Sent from the Apache Qpid users mailing list archive at Nabble.com.
---------------------------------------------------------------------
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]
