00001
00002
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021 #ifndef _Execution_
00022 #define _Execution_
00023
00024 #include "qpid/framing/SequenceNumber.h"
00025 #include "Demux.h"
00026
00027 namespace qpid {
00028 namespace client {
00029
00033 class Execution
00034 {
00035 public:
00036 virtual ~Execution() {}
00037 virtual void sendSyncRequest() = 0;
00038 virtual void sendFlushRequest() = 0;
00039 virtual void completed(const framing::SequenceNumber& id, bool cumulative, bool send) = 0;
00040 virtual Demux& getDemux() = 0;
00041 virtual bool isComplete(const framing::SequenceNumber& id) = 0;
00042 virtual bool isCompleteUpTo(const framing::SequenceNumber& id) = 0;
00043 virtual void setCompletionListener(boost::function<void()>) = 0;
00044 virtual void syncWait(const framing::SequenceNumber& id) = 0;
00045 virtual framing::SequenceNumber lastSent() const = 0;
00046 };
00047
00048 }}
00049
00050 #endif