Replicate session state for un-acknowledged messages to new cluster members.

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

1 files changed, 5 insertions, 5 deletions

diff --git a/cpp/src/qpid/client/LocalQueue.h b/cpp/src/qpid/client/LocalQueue.h
index 9fe72762c3..3be2293810 100644
--- a/cpp/src/qpid/client/LocalQueue.h
+++ b/cpp/src/qpid/client/LocalQueue.h
@@ -56,14 +56,14 @@ class LocalQueue {
      */
     bool get(Message& result, sys::Duration timeout=0);
 
-    /** Get the next message off the local queue, or wait for a
-     * message from the broker queue.
-     *@exception ClosedException if subscription has been closed.
+    /** Get the next message off the local queue, or wait up to the timeout
+     * for message from the broker queue.
+     *@exception ClosedException if subscription is closed or timeout exceeded.
      */
-    Message get();
+    Message get(sys::Duration timeout=sys::TIME_INFINITE);
 
     /** Synonym for get(). */
-    Message pop();
+    Message pop(sys::Duration timeout=sys::TIME_INFINITE);
 
     /** Return true if local queue is empty. */
     bool empty() const;