#include <SessionState.h>
Public Member Functions | |
void | setCommandPoint (const SessionPoint &point) |
Set the command point. | |
bool | record (const framing::AMQFrame &f) |
Returns true if frame should be be processed, false if it is a duplicate. | |
void | completed (SequenceNumber command, bool cumulative=false) |
Command completed locally. | |
void | knownCompleted (const SequenceSet &commands) |
Peer has indicated commands are known completed. | |
const SessionPoint & | getExpected () const |
Get the incoming command point. | |
const SessionPoint & | getReceived () const |
Get the received high-water-mark, may be > getExpected() during replay. | |
const SequenceSet & | getUnknownComplete () const |
Completed commands that the peer may not know about. | |
SequenceNumber | getCurrent () const |
ID of the command currently being handled. |
Idempotence barrier for duplicate commands, tracks completion and of received commands.
void qpid::SessionState::ReceiveState::setCommandPoint | ( | const SessionPoint & | point | ) |
Set the command point.
bool qpid::SessionState::ReceiveState::record | ( | const framing::AMQFrame & | f | ) |
Returns true if frame should be be processed, false if it is a duplicate.
SequenceNumber qpid::SessionState::ReceiveState::getCurrent | ( | ) | const |
ID of the command currently being handled.