From 1150be6d66a943d899e25af4cb876e7f68c657d9 Mon Sep 17 00:00:00 2001 From: Gordon Sim Date: Tue, 31 Oct 2006 15:38:36 +0000 Subject: Added doc & unit tests. git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@469530 13f79535-47bb-0310-9956-ffa450edef68 --- cpp/src/qpid/broker/AccumulatedAck.cpp | 2 +- cpp/src/qpid/broker/TxPublish.h | 10 ++++++++++ 2 files changed, 11 insertions(+), 1 deletion(-) (limited to 'cpp/src') diff --git a/cpp/src/qpid/broker/AccumulatedAck.cpp b/cpp/src/qpid/broker/AccumulatedAck.cpp index 060e940309..84ddcee556 100644 --- a/cpp/src/qpid/broker/AccumulatedAck.cpp +++ b/cpp/src/qpid/broker/AccumulatedAck.cpp @@ -25,7 +25,7 @@ void AccumulatedAck::update(u_int64_t tag, bool multiple){ if(multiple){ if(tag > range) range = tag; //else don't care, it is already counted - }else if(tag < range){ + }else if(tag > range){ individual.push_back(tag); } } diff --git a/cpp/src/qpid/broker/TxPublish.h b/cpp/src/qpid/broker/TxPublish.h index 01bb573fe2..5076e0f56f 100644 --- a/cpp/src/qpid/broker/TxPublish.h +++ b/cpp/src/qpid/broker/TxPublish.h @@ -29,6 +29,16 @@ namespace qpid { namespace broker { + /** + * Defines the behaviour for publish operations on a + * transactional channel. Messages are routed through + * exchanges when received but are not at that stage delivered + * to the matching queues, rather the queues are held in an + * instance of this class. On prepare() the message is marked + * enqueued to the relevant queues in the MessagesStore. On + * commit() the messages will be passed to the queue for + * dispatch or to be added to the in-memory queue. + */ class TxPublish : public TxOp, public Deliverable{ class Prepare{ Message::shared_ptr& msg; -- cgit v1.2.1