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