diff options
| author | Aidan Skinner <aidan@apache.org> | 2008-02-21 15:28:43 +0000 |
|---|---|---|
| committer | Aidan Skinner <aidan@apache.org> | 2008-02-21 15:28:43 +0000 |
| commit | a7901852d59190651225843843d013ac34e77b52 (patch) | |
| tree | 4e2a372d6a86fa90f6a1135cbd482d6ec674bf11 /java/client | |
| parent | 3047c0ec2d581f4b51c77fec84fbf0bec8599573 (diff) | |
| download | qpid-python-a7901852d59190651225843843d013ac34e77b52.tar.gz | |
QPID-785: Make sure queue browser consumers are auto-close, add test for browsing an empty queue. Refactor QueueBrowserTest a little to split up responsibilities a bit.
We should move the sendMessage stuff to a super class, there are at least 4 implementations of that kicking about.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@629824 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/client')
| -rw-r--r-- | java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java b/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java index 28e5992b26..4171e9bf9b 100644 --- a/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java +++ b/java/client/src/main/java/org/apache/qpid/client/AMQQueueBrowser.java @@ -88,6 +88,7 @@ public class AMQQueueBrowser implements QueueBrowser checkState(); final BasicMessageConsumer consumer = (BasicMessageConsumer) _session.createBrowserConsumer(_queue, _messageSelector, false); + consumer.closeWhenNoMessages(true); _consumers.add(consumer); return new Enumeration() |