delta/python-packages/qpid-python.git/qpid/cpp/src/tests/ClientSessionTest.cpp, branch 0.5-fix

Use qpid sleep rather than CRT sleep to build on Windows

2009-02-02T22:11:20+00:00

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

QPID-1613: Ensure that the rule registered with the demuxer for LocalQueue subscriptions is removed when they are cancelled.

2009-01-23T14:08:42+00:00

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

QPID-1560: add support for a qpid.exclusive-binding option on direct exchange that causes the binding specified to be the only one for the given key. I.e. if there is already a binding at this exchange with this key it will be atomically updated to bind the new queue.

2009-01-07T10:46:53+00:00

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

QPID-1527: Added exclusive option to SubscriptionSettings and accompanying test.

2008-12-10T23:26:18+00:00

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

QPID-1478: ensure concurrent publishers work correctly (as well as reported assertion, the test uncovered a potential deadlock due to bounds being expanded before frames were added to queue).

2008-11-24T18:37:37+00:00

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

SubscriptionManager and Dispatcher were missing wait() methods meaning that if start was called there was no way to join with the dispatch thread and shutdown cleanly. Fixed by adding that method.

2008-11-06T10:47:57+00:00

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

Added ability to release messages through the Subscription class (+test)

2008-11-05T21:12:54+00:00

Added another mode for managing completion (+test)
Fixed regression where bytes credit was not reallocated in windowing mode after an accept/release
Fixed regression where subscribe request is issued before listener is registered with dispatcher



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

Client API change: Centralize access to subscription status, better control of acquire/accept.

2008-10-25T01:55:06+00:00

client/AckPolicy: removed, functionality moved to Subscription and SubscriptionSettings
client/SubscriptionSettings: struct aggregates flow control & accept-acquire parameters for subscribe.
client/Subscription: represents active subscription. Query settings, unacked messages, manual accept/acquire
client/SubscriptionManager: use AcceptMode, AcquireMode enums rather than confusing bools.

Issues addressed by the change:
 - old use of bool for acceptMode was inverted wrt AMQP enum values, bools are confusing.
 - old AckPolicy was broken - not possible to access the instance associated with an active subscription
 - old AckPolicy did not provide a way to do manual acquire, only accept.
 - setting values on SubscriptionManager to apply to subsequent subscriptions is awkward & error-prone, now can use SubscriptionSettings to control on each subscribe individually.
 - a subscription is a central concept in AMQP, it deserves to be a class. Subscription and SubscriptionSettings provides a single point for future expansion of interactions with a a Subscription.


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

Periodically purge expired messages from queues

2008-10-13T17:09:06+00:00

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

rubygen/framing.0-10/constants.rb: create functions for all 3 exception subclasses.

2008-10-08T00:36:42+00:00

client: added session suspend/resume functions, resume not implemented yet.
ClientSessionTest: enabled compilation of suspend/resume tests with expected failures.


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