Session resume support in client & broker: Client can resume a session

after voluntary suspend() or network failure. Frames lost in network
failure are automatically re-transmitted for transparent re-connection.

client::Session improvements:
 - Locking to avoid races between network & user threads.
 - Replaced client::StateManager with sys::StateMonitor - avoid heap allocation.

qpid::Exception clean up:
 - use QPID_MSG consistently to format exception messages.
 - throw typed exceptions (in reply_exceptions.h) for AMQP exceptions.
 - re-throw correct typed exception on client for exceptions from broker.
 - Removed QpidError.h

rubygen/templates/constants.rb: 
 - constants.h: Added FOO_CLASS_ID and FOO_BAR_METHOD_ID constants.
 - reply_constants.h: Added throwReplyException(code, text)
 
log::Logger:
 - Fixed shutdown race in Statement::~Initializer()


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

1 files changed, 8 insertions, 6 deletions

diff --git a/cpp/src/qpid/client/ConnectionImpl.h b/cpp/src/qpid/client/ConnectionImpl.h
index f20534f1aa..46bd5b685d 100644
--- a/cpp/src/qpid/client/ConnectionImpl.h
+++ b/cpp/src/qpid/client/ConnectionImpl.h
@@ -51,14 +51,14 @@ class ConnectionImpl : public framing::FrameHandler,
     bool isClosed;
 
     void incoming(framing::AMQFrame& frame);    
-    void closed();
-    void closedByPeer(uint16_t, const std::string&);
+    void closed(uint16_t, const std::string&);
     void idleOut();
     void idleIn();
     void shutdown();
-    void signalClose(uint16_t, const std::string&);
-    void assertNotClosed();
-public:
+
+    template <class F> void forChannels(F functor);
+
+  public:
     typedef boost::shared_ptr<ConnectionImpl> shared_ptr;
 
     ConnectionImpl(boost::shared_ptr<Connector> c);
@@ -69,7 +69,9 @@ public:
               const std::string& pwd = "guest", 
               const std::string& virtualhost = "/");
     void close();
-    void handle(framing::AMQFrame& frame);    
+    void handle(framing::AMQFrame& frame);
+    void erase(uint16_t channel);
+    boost::shared_ptr<Connector> getConnector() { return connector; }
 };
 
 }}