diff options
| author | Martin Ritchie <ritchiem@apache.org> | 2006-12-20 14:54:01 +0000 |
|---|---|---|
| committer | Martin Ritchie <ritchiem@apache.org> | 2006-12-20 14:54:01 +0000 |
| commit | 845d61c8a2f1fe68d4bb2f20756c2c6180027b45 (patch) | |
| tree | 364ea07b060979db62e96de1661560c829cb0f1c /qpid/java/cluster/src | |
| parent | c7dc1bdb194bc455f1fbb6a1b941275855a042d7 (diff) | |
| download | qpid-python-845d61c8a2f1fe68d4bb2f20756c2c6180027b45.tar.gz | |
QPID-101
Initial Implementation of Queue Browsing by Robert Godfrey and Martin Ritchie
AMQChannel.java - record messages browsed so not to discard them on ack.
FilterManagerFactory.java - Added a NoConsumerFilter
ConcurrentSelectorDeliveryManager.java - Update to send browsers messages without taking the message from other consumers
Subscription.java - Added autoClose and isBrowser methods
SubscriptionTestHelper.java / RemoteSubscriptionImpl.java / SubscriptionImpl.java - implemented new interface methods
Added NoConsumerFilter.java
Patches from Rob Godfrey for client implmentation
AMQSession.java - Added AUTO_CLOSE and NO_CONSUME properties to arguments FieldTable for consume method.
BasicMessageConsumer.java - updates to correctly close consumer when an BasicCancel is received from the broker.
AMQProtocolSession.java - method to allow cancellation of the client
AMQStateManager.java - added handler for BasicCancelOkMethodHandler.java
Added new AMQQueueBrowser.java BasicCancelOkMethodHandler.java
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk@489106 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/cluster/src')
| -rw-r--r-- | qpid/java/cluster/src/main/java/org/apache/qpid/server/queue/RemoteSubscriptionImpl.java | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/qpid/java/cluster/src/main/java/org/apache/qpid/server/queue/RemoteSubscriptionImpl.java b/qpid/java/cluster/src/main/java/org/apache/qpid/server/queue/RemoteSubscriptionImpl.java index cc7f6ecd2a..c751e4a011 100644 --- a/qpid/java/cluster/src/main/java/org/apache/qpid/server/queue/RemoteSubscriptionImpl.java +++ b/qpid/java/cluster/src/main/java/org/apache/qpid/server/queue/RemoteSubscriptionImpl.java @@ -122,6 +122,21 @@ class RemoteSubscriptionImpl implements Subscription, WeightedSubscriptionManage //no-op -- if selectors are implemented on RemoteSubscriptions then look at SubscriptionImpl } + public boolean isAutoClose() + { + return false; + } + + public void close() + { + //no-op + } + + public boolean isBrowser() + { + return false; //To change body of implemented methods use File | Settings | File Templates. + } + public void sendNextMessage(AMQQueue queue) { |