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 /cpp/tests/EventChannelThreadsTest.cpp | |
| 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 'cpp/tests/EventChannelThreadsTest.cpp')
0 files changed, 0 insertions, 0 deletions