summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/qpid/client/ConnectionImpl.h
diff options
context:
space:
mode:
Diffstat (limited to 'qpid/cpp/src/qpid/client/ConnectionImpl.h')
-rw-r--r--qpid/cpp/src/qpid/client/ConnectionImpl.h17
1 files changed, 10 insertions, 7 deletions
diff --git a/qpid/cpp/src/qpid/client/ConnectionImpl.h b/qpid/cpp/src/qpid/client/ConnectionImpl.h
index cc81500b18..b7d4d423b2 100644
--- a/qpid/cpp/src/qpid/client/ConnectionImpl.h
+++ b/qpid/cpp/src/qpid/client/ConnectionImpl.h
@@ -7,9 +7,9 @@
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@@ -22,6 +22,7 @@
#ifndef _ConnectionImpl_
#define _ConnectionImpl_
+#include "qpid/client/ClientImportExport.h"
#include "qpid/client/Bounds.h"
#include "qpid/client/ConnectionHandler.h"
@@ -44,9 +45,11 @@ class Connector;
struct ConnectionSettings;
class SessionImpl;
-class ConnectionImpl : public Bounds,
+// TODO aconway 2011-04-05: exposed for use by cluster::UpdateClient,
+// clean up dependencies.
+class QPID_CLIENT_CLASS_EXTERN ConnectionImpl : public Bounds,
public framing::FrameHandler,
- public sys::TimeoutHandler,
+ public sys::TimeoutHandler,
public sys::ShutdownHandler,
public boost::enable_shared_from_this<ConnectionImpl>
{
@@ -54,7 +57,7 @@ class ConnectionImpl : public Bounds,
static const uint16_t NEXT_CHANNEL;
- SessionMap sessions;
+ SessionMap sessions;
ConnectionHandler handler;
boost::scoped_ptr<Connector> connector;
framing::ProtocolVersion version;
@@ -82,13 +85,13 @@ class ConnectionImpl : public Bounds,
static void init();
static boost::shared_ptr<ConnectionImpl> create(framing::ProtocolVersion version, const ConnectionSettings& settings);
~ConnectionImpl();
-
+
void open();
bool isOpen() const;
boost::shared_ptr<SessionImpl> newSession(const std::string& name, uint32_t timeout, uint16_t channel=NEXT_CHANNEL);
void addSession(const boost::shared_ptr<SessionImpl>&, uint16_t channel=NEXT_CHANNEL);
-
+
void close();
void handle(framing::AMQFrame& frame);
void erase(uint16_t channel);