diff options
Diffstat (limited to 'cpp/src')
| -rw-r--r-- | cpp/src/qpid/broker/AccumulatedAck.cpp | 2 | ||||
| -rw-r--r-- | cpp/src/qpid/broker/TxPublish.h | 10 |
2 files changed, 11 insertions, 1 deletions
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; |