00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021 #ifndef _TxAccept_
00022 #define _TxAccept_
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 {
00037 class TxAccept : public TxOp{
00038 framing::AccumulatedAck& acked;
00039 std::list<DeliveryRecord>& unacked;
00040
00041 public:
00047 TxAccept(framing::AccumulatedAck& acked, std::list<DeliveryRecord>& unacked);
00048 virtual bool prepare(TransactionContext* ctxt) throw();
00049 virtual void commit() throw();
00050 virtual void rollback() throw();
00051 virtual ~TxAccept(){}
00052 };
00053 }
00054 }
00055
00056
00057 #endif