Bug 618865 - Add support in the JMS client for "mode" option defined in the new addressing format
Add support in the JMS client for "mode" option defined in the new addressing...
Product: Red Hat Enterprise MRG
Classification: Red Hat
Component: qpid-java (Show other bugs)
All Linux
medium Severity medium
: 1.3
: ---
Assigned To: Rajith Attapattu
MRG Quality Engineering
Depends On:
  Show dependency treegraph
Reported: 2010-07-27 18:00 EDT by Rajith Attapattu
Modified: 2013-02-25 05:49 EST (History)
1 user (show)

See Also:
Fixed In Version: 0.10
Doc Type: Bug Fix
Doc Text:
Story Points: ---
Clone Of:
Last Closed: 2013-02-25 05:49:41 EST
Type: ---
Regression: ---
Mount Type: ---
Documentation: ---
Verified Versions:
Category: ---
oVirt Team: ---
RHEL 7.3 requirements from Atomic Host:
Cloudforms Team: ---

Attachments (Terms of Use)

  None (edit)
Description Rajith Attapattu 2010-07-27 18:00:22 EDT
Description of problem:
The mode option allows to specify whether messages should be consumed or read in browsing mode. 
All though JMS has a QueueBrowser class, it only allows messages to be browsed synchronously.
The above option allows an end-user to leverage the MessageListener to browse message asynchronously.

Ex. The following shows an example addressing string which creates a browse mode Consumer on a ring queue.

"my-ring-queue; {create: always, mode: browse, " +
                "node: {x-bindings: [{exchange : 'amq.direct', key : test}], " +
                       "x-declare:{'qpid.policy_type':ring, 'qpid.max_count':2}}}";
Comment 1 Rajith Attapattu 2010-07-29 09:28:23 EDT
Fixed in upstream (tracked via QPID-2738)

Git commit URL


Steps to test
To test this, you could use the address given in the description.

1. run o.a.q.example.Drain -f <address-string>
2. Send two messages to amq.direct exchange with rk=test
   Ex o.a.q.example.Spout -c MSG$num "amq.direct/test"

3. Observe that Drain prints the examples.
4. Shutdown drain and restart it, you should see the two messages again.

Note You need to log in before you can comment on or make changes to this bug.