delta/python-packages/qpid-python.git/cpp/src/qpid/broker/Consumer.h, branch qpid.0-10

QPID-944: do no-local checking where requested when there is an exclusive subscription active

2008-04-22T12:05:52+00:00

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

- Refactored RefCounted class to avoid virtual inheritance

2008-03-24T17:43:55+00:00

- Removed extraneous includes and definitions from RefCounted.h
- Fixed all the places that were relying on RefCounted.h to be including the
  intrusive_ptr header file and were assuming that something had imported
  intrusive_ptr into the qpid namespace


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

Altered management of delivery records to support separateion of completion (which drives flow control) and acceptance.

2008-03-07T13:20:02+00:00

Converted flow control python tests.



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

Changes to threading: queues serialiser removed, io threads used to drive dispatch to consumers

2007-11-29T11:54:17+00:00

Fix to PersistableMessage: use correct lock when accessing synclist, don't hold enqueue lock when notifying queues



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

Replaced shared_ptr with intrusive_ptr for qpid::Broker::Message.

2007-11-14T21:02:14+00:00

Gives 9% reduction in broker heap use (perftest --count 100000.)


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

- enable the ability to lazy load from async store

2007-11-08T18:46:53+00:00

- the ci has a raw ptr for Queue in QueuedMessage, if any has 
any concerns, ping me and I will convert it to an auto_ptr
Carl.



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

Hack for no-local when used with jms topics

2007-10-23T14:50:56+00:00

Fix for releasing of exclusive ownership of queues second time around



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

Use shared pointers for consumers (held by queues and sessions) to prevent having to hold lock across deliver() while avoiding invocation on stale pointers.

2007-10-17T08:59:44+00:00

Ensure auto-deleted queues are properly cleaned up (i.e. are unbound from exchanges) to avoid leaking memory as messages are accumulated in inaccessible queues. (some cleanup to follow on this)



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

Initial implementation (plus very simple tests) of message.acquire, message.release, message.reject and message.flush.

2007-09-03T17:35:35+00:00

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

Pass QueuedMessage to queues consumers. This records the position of that message in the queue which is need to handle rlease and acquire.

2007-08-31T16:45:20+00:00

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