summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/Connection.h
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2008-10-09 19:36:51 +0000
committerAlan Conway <aconway@apache.org>2008-10-09 19:36:51 +0000
commitd6901e52ab3ee9c40eddc4ad3b4787127c36d874 (patch)
tree85b9ba2e0d0922be150480392ec1b706a6df5cd0 /cpp/src/qpid/client/Connection.h
parent016ae5acebab0eaf6dd70f5d4d653fdfee93925d (diff)
downloadqpid-python-d6901e52ab3ee9c40eddc4ad3b4787127c36d874.tar.gz
Client-side support for amq.faiover exchange. Connection::getKnownBrokers provides latest list.
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@703237 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/Connection.h')
-rw-r--r--cpp/src/qpid/client/Connection.h9
1 files changed, 5 insertions, 4 deletions
diff --git a/cpp/src/qpid/client/Connection.h b/cpp/src/qpid/client/Connection.h
index a1575dd524..a5ea40ff38 100644
--- a/cpp/src/qpid/client/Connection.h
+++ b/cpp/src/qpid/client/Connection.h
@@ -32,6 +32,7 @@ class Url;
namespace client {
class ConnectionSettings;
+class ConnectionImpl;
/**
* Represents a connection to an AMQP broker. All communication is
@@ -42,9 +43,7 @@ class ConnectionSettings;
*/
class Connection
{
- framing::ChannelId channelIdCounter;
framing::ProtocolVersion version;
- uint16_t max_frame_size;
protected:
boost::shared_ptr<ConnectionImpl> impl;
@@ -55,6 +54,7 @@ class Connection
* @see open()
*/
Connection();
+
~Connection();
/**
@@ -157,7 +157,7 @@ class Connection
* If the name is empty (the default) then a unique name will be
* chosen using a Universally-unique identifier (UUID) algorithm.
*/
- Session newSession(const std::string& name=std::string());
+ Session newSession(const std::string& name=std::string(), uint32_t timeoutSeconds = 0);
/**
* Resume a suspended session. A session may be resumed
@@ -167,7 +167,8 @@ class Connection
bool isOpen() const;
-
+ std::vector<Url> getKnownBrokers();
+
friend class ConnectionAccess; ///<@internal
friend class SessionBase_0_10; ///<@internal
};