delta/python-packages/qpid-python.git/java, branch event-queue-2006-12-20

QPID-225

2006-12-20T17:04:33+00:00

Applied Patch for queue browsing with client acknowledgement

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489140 13f79535-47bb-0310-9956-ffa450edef68

renamed the jar

2006-12-20T15:25:45+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489113 13f79535-47bb-0310-9956-ffa450edef68

QPID-101

2006-12-20T14:54:01+00:00

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

Updated FilterTypes to be more accurate NO_CONSUME and AUTO_CLOSE

2006-12-20T13:26:12+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489083 13f79535-47bb-0310-9956-ffa450edef68

QPID-223

2006-12-20T13:22:27+00:00

Applied patch from Rupert Smith

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489082 13f79535-47bb-0310-9956-ffa450edef68

Added new enum for AMQP Filter types

2006-12-20T12:57:27+00:00

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489078 13f79535-47bb-0310-9956-ffa450edef68

QPID-21 outstanding issues:

2006-12-20T12:46:20+00:00

Fixed an issue where a consumer with no_local set would not have its filters applied to messages.
Fixed problem where new consumers would start with an empty PDQ rather than checking the existing queue of messages for messages of interest.

AMQQueue.java - Added code check exisiting queue data for messages for the new subscriber with a filter.
DeliveryManager.java - added populatePreDeliveryQueue
SynchronizedDeliveryManager.java/ConcurrentDeliveryManager.java - implemented new DeliveryManager.java interface
SubscriptionImpl.java - fixed issue with no_local subscribers had their filters ignored.


git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@489070 13f79535-47bb-0310-9956-ffa450edef68

QPID-222

2006-12-19T17:02:19+00:00

ensured that the TXBuffer of a message is set to null when re queuing.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488726 13f79535-47bb-0310-9956-ffa450edef68

Maven output clean up.

2006-12-19T16:14:28+00:00

Mainly removed exception stack traces from expected exceptions.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488715 13f79535-47bb-0310-9956-ffa450edef68

Maven output clean up.

2006-12-19T16:09:39+00:00

Mainly removed exception stack traces from expected exceptions.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@488713 13f79535-47bb-0310-9956-ffa450edef68