Changes to Session API:

 - Session is synchronous, no futures.
 - AsyncSession is async, returns futures.
 - Conversion functions sync(s) async(s) return a sync/async view of session s. 
 - Connection::newSession - takes name, no timeout
 - SessionBase::getId - returns SessionId not UUID.


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

1 files changed, 5 insertions, 5 deletions

diff --git a/cpp/src/qpid/client/SubscriptionManager.h b/cpp/src/qpid/client/SubscriptionManager.h
index 4ccb95c968..4ff962f67b 100644
--- a/cpp/src/qpid/client/SubscriptionManager.h
+++ b/cpp/src/qpid/client/SubscriptionManager.h
@@ -45,10 +45,10 @@ class SubscriptionManager : public sys::Runnable
     typedef sys::Mutex::ScopedLock Lock;
     typedef sys::Mutex::ScopedUnlock Unlock;
 
-    Completion subscribeInternal(const std::string& q, const std::string& dest);
+    void subscribeInternal(const std::string& q, const std::string& dest);
     
     qpid::client::Dispatcher dispatcher;
-    qpid::client::Session& session;
+    qpid::client::Session session;
     uint32_t messages;
     uint32_t bytes;
     bool window;
@@ -58,7 +58,7 @@ class SubscriptionManager : public sys::Runnable
     bool autoStop;
     
   public:
-    SubscriptionManager(Session& session);
+    SubscriptionManager(const Session& session);
     
     /**
      * Subscribe a MessagesListener to receive messages from queue.
@@ -68,7 +68,7 @@ class SubscriptionManager : public sys::Runnable
      *@param tag Unique destination tag for the listener.
      * If not specified, the queue name is used.
      */
-    Completion subscribe(MessageListener& listener,
+    void subscribe(MessageListener& listener,
                          const std::string& queue,
                          const std::string& tag=std::string());
 
@@ -79,7 +79,7 @@ class SubscriptionManager : public sys::Runnable
      *@param tag Unique destination tag for the listener.
      * If not specified, the queue name is used.
      */
-    Completion subscribe(LocalQueue& localQueue,
+    void subscribe(LocalQueue& localQueue,
                    const std::string& queue,
                    const std::string& tag=std::string());