delta/python-packages/qpid-python.git/qpid/cpp/src/tests/ClientSessionTest.cpp, branch M4-RCs

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

QPID-1198 (Partial): Added explicit namespaces that the Sun C++ requires (that gcc doesn't)

2008-07-29T20:26:32+00:00

Patches from Manuel Teira.
It's not clear at this point whether there is a compiler problem with gcc that it does find
the symbols in the namespaces or SunCC that it doesn't!


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

Fixed bug in SubscriptionManager::get() where flush was issued before waiting and if message showed up after flush completed but before wait was finished there was no credit (due to flush) to deliver it to the waiting client. Added test for thise case.

2008-07-25T10:16:22+00:00

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

Honour timeout in BlockingQueue::pop(); added test for SubscriptionManager::get() where no message exists.

2008-07-10T08:39:10+00:00

 


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