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 | fc6d79eb365027d1fdda43ae0081f72dd45b7896 (patch) | |
| tree | b8bd2f4f43faf9ce43438b7503e548e111f79512 /java/cluster/src | |
| parent | 7ec92c0a43be9e5934b35565a7f46eb83e36f6d1 (diff) | |
| download | qpid-python-fc6d79eb365027d1fdda43ae0081f72dd45b7896.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/qpid@489106 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/cluster/src')
| -rw-r--r-- | java/cluster/src/main/java/org/apache/qpid/server/queue/RemoteSubscriptionImpl.java | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/java/cluster/src/main/java/org/apache/qpid/server/queue/RemoteSubscriptionImpl.java b/java/cluster/src/main/java/org/apache/qpid/server/queue/RemoteSubscriptionImpl.java index cc7f6ecd2a..c751e4a011 100644 --- a/java/cluster/src/main/java/org/apache/qpid/server/queue/RemoteSubscriptionImpl.java +++ b/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) { |