00001 #ifndef _framing_Requester_h
00002 #define _framing_Requester_h
00003
00004
00005
00006
00007
00008
00009
00010
00011
00012
00013
00014
00015
00016
00017
00018
00019
00020
00021
00022 #include <set>
00023 #include "AMQRequestBody.h"
00024 #include "AMQResponseBody.h"
00025
00026 namespace qpid {
00027 namespace framing {
00028
00029 class AMQRequestBody;
00030 class AMQResponseBody;
00031
00037 class Requester
00038 {
00039 public:
00040 Requester();
00041
00043 void sending(AMQRequestBody::Data&);
00044
00046 void processed(const AMQResponseBody::Data&);
00047
00049 RequestId getNextId() { return lastId + 1; }
00050
00052 RequestId getFirstAckRequest() { return firstAckRequest; }
00053
00055 RequestId getLastAckRequest() { return lastAckRequest; }
00056
00057 private:
00058 RequestId lastId;
00059 ResponseId responseMark;
00060 ResponseId firstAckRequest;
00061 ResponseId lastAckRequest;
00062 };
00063
00064 }}
00065
00066
00067
00068 #endif