diff options
| author | Alan Conway <aconway@apache.org> | 2010-10-18 19:36:13 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2010-10-18 19:36:13 +0000 |
| commit | a08d54e27d4e91b52c5979cc566ab3e933878983 (patch) | |
| tree | 7f57ad88051e4a02f52d4bdf395968549e24f57a /cpp/src/qpid/broker/Queue.h | |
| parent | 8e53bc375ef2bfb4b05cc32b4a8c0042d95b9ec2 (diff) | |
| download | qpid-python-a08d54e27d4e91b52c5979cc566ab3e933878983.tar.gz | |
Introduce broker::Cluster interface.
See cpp/src/qpid/cluster/new-cluster-design.txt and new-cluster-plan.txt.
qpid/cpp/src/tests/BrokerClusterCalls.cpp is a unit test that verifies
the broker makes the expected calls on broker::Cluster in various situations.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1023966 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Queue.h')
| -rw-r--r-- | cpp/src/qpid/broker/Queue.h | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/cpp/src/qpid/broker/Queue.h b/cpp/src/qpid/broker/Queue.h index 96c79d1b92..572f3dc0e2 100644 --- a/cpp/src/qpid/broker/Queue.h +++ b/cpp/src/qpid/broker/Queue.h @@ -259,6 +259,13 @@ class Queue : public boost::enable_shared_from_this<Queue>, bool enqueue(TransactionContext* ctxt, boost::intrusive_ptr<Message>& msg, bool suppressPolicyCheck = false); void enqueueAborted(boost::intrusive_ptr<Message> msg); + + /** Message acknowledged, dequeue it. */ + QPID_BROKER_EXTERN void accept(TransactionContext* ctxt, const QueuedMessage &msg); + + /** Message rejected, dequeue it and re-route to alternate exchange if necessary. */ + QPID_BROKER_EXTERN void reject(const QueuedMessage &msg); + /** * dequeue from store (only done once messages is acknowledged) */ |