00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021 #ifndef _DtxAck_
00022 #define _DtxAck_
00023
00024 #include <algorithm>
00025 #include <functional>
00026 #include <list>
00027 #include "qpid/framing/AccumulatedAck.h"
00028 #include "DeliveryRecord.h"
00029 #include "TxOp.h"
00030
00031 namespace qpid {
00032 namespace broker {
00033 class DtxAck : public TxOp{
00034 std::list<DeliveryRecord> pending;
00035
00036 public:
00037 DtxAck(const framing::AccumulatedAck& acked, std::list<DeliveryRecord>& unacked);
00038 virtual bool prepare(TransactionContext* ctxt) throw();
00039 virtual void commit() throw();
00040 virtual void rollback() throw();
00041 virtual ~DtxAck(){}
00042 };
00043 }
00044 }
00045
00046
00047 #endif