delta/python-packages/qpid-python.git/cpp/src/qpid/broker/Queue.cpp, branch QPID-6125-ProtocolRefactoring

QPID-5973: HA cluster state may get stuck in recovering

2014-08-08T09:23:54+00:00

A backup queue is considered "ready" when all messages up to the first guarded
position have either been replicated and acknowledged or dequeued.

Previously this was implemented by waiting for the replicationg subscription to
advance to the first guarded position and wating for all expected acks. However
if messages are dequeued out-of-order (which happens with transactions) there
can be a gap at the tail of the queue. The replicating subscription will not
advance past this gap because it only advances when there are messages to
consume. This resulted in backups stuck in catch-up. The recovering primary has
a time-out for backups that never re-connect, but if they connect sucessfully
and don't disconnect, the primary assumes they will become ready and waits -
causing the primary to be stuck in "recovering".

The fixes is to notify a replicating subscription if it becomes "stopped"
because there are no more messages available on the queue. This implies that
either it is at the tail OR there are no more messags until the tail. Either way
we should consider this "ready" from the point of view of HA catch-up.

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

[QPID-5929]: Mark deprecated QMF fields as Deprecated and do some relevant code cleanup

2014-07-29T10:22:17+00:00

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

QPID-3921: Refactored Broker::Options into its own independent class

2014-07-01T19:12:38+00:00

- Now called BrokerOptions
- Added extra getters to Broker so that nothing else needs to know
  about BrokerOptions
- Significantly reduces header coupling as lots of files include
  Broker.h, but now don't need Options.h

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

QPID-5835: [C++ broker] Broker recovery forgets auto-delete flag on queues and exchanges

2014-06-21T20:48:01+00:00

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

QPID-5817: [C++ broker] Improve ACL authorisation of QMF methods and queries

2014-06-18T07:40:22+00:00

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

QPID-5793: prevent leak due to concurrent bind and delete

2014-06-03T19:04:45+00:00

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

QPID-5793: prevent deadlock between timer and consume

2014-06-03T19:04:39+00:00

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

QPID-5748: [C++ broker] Make Queue::purgeExpired more efficient; remove ExpiryPolicy

2014-05-28T07:16:57+00:00

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

QPID-5560: HA tests do not use AMQP 1.0

2014-04-07T21:22:55+00:00

The HA tests were using only AMQP 0-10.
Modified the tests to use AMQP 1.0 if available (still use 0-10 if 1.0 is not available)
Fixed bugs uncovered both in the tests and in the AMQP 1.0 implementation.

Summary of changes:
- brokertest.py: configurable support for of swig vs. native and amqp0-10 vs. 1.0
  - default to swig+amqp1.0 if swig is available, native+amqp0-10 otherwise

- qpidtoollibs/broker.py: enable use of swig client with BrokerAgent

- Swig python client:
  - support for passing client_properties/properties.
    - expose AddressHelper pn_data read/write as PnData helper class
  - set sender/receiver capacity on creation
  - limited disposition support - rejected messages.
  - support for additional timeout parameters
  - expose messaging::Logger, allow log configuration to be set from python.

- ha_tests.py:
  - bind, delete policies not supported by AMQP 1.0, switched to using BrokerAgent QMF.
  - pass protocol:amqp1.0 connection-option to c++ test clients (qpid-send, qpid-receive)
  - TX tests forsce use of 0-10 protocol (but still with Swig client if enabled.)

- Broker fixes:
  - Queue::Settings::isTemporary was set in the 0-10 SessionAdapter, moved to Broker::createQueue.
  - broker::amqp::Session was always setting an exclusive owner in createQueue

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

QPID-5667: C++ broker: QMF subscribe events are not raised with AMQP 1.0

2014-04-07T21:22:32+00:00

The raise event logic for subscribe/unsubscribe events was in 0-10 specific code.
Moved it into Queue.cpp so events are generated regardless of protocol.

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