Cluster replicates session command sequence state and consumers to newcomers.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@698666 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 15 insertions, 2 deletions

diff --git a/cpp/src/qpid/SessionState.h b/cpp/src/qpid/SessionState.h
index 10937b7a1e..bf4ff6d326 100644
--- a/cpp/src/qpid/SessionState.h
+++ b/cpp/src/qpid/SessionState.h
@@ -130,8 +130,8 @@ class SessionState {
     virtual SessionPoint senderGetReplayPoint() const;
 
     /** Peer expecting commands from this point.
-        virtual *@return Range of frames to be replayed.
-    */
+     *@return Range of frames to be replayed.
+     */
     virtual ReplayRange senderExpected(const SessionPoint& expected);
 
     // ==== Functions for receiver state
@@ -168,6 +168,19 @@ class SessionState {
     /** ID of the command currently being handled. */
     virtual SequenceNumber receiverGetCurrent() const;
 
+    /** Set the state variables, used to create a session that will resume
+     *  from some previously established point.
+     */
+    virtual void setState(
+        const SequenceNumber& replayStart,
+        const SequenceNumber& sendCommandPoint,
+        const SequenceSet& sentIncomplete,
+        const SequenceNumber& expected,
+        const SequenceNumber& received,
+        const SequenceSet& unknownCompleted,
+        const SequenceSet& receivedIncomplete
+    );
+
   private:
 
     struct SendState {