diff options
| author | Alan Conway <aconway@apache.org> | 2012-06-28 19:55:40 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2012-06-28 19:55:40 +0000 |
| commit | e100648803b98ee2786475368ebd473945b96396 (patch) | |
| tree | 43759e998dac1e1a7225a53bb1d31b13a0251075 /cpp/src | |
| parent | 482c47549d216010fbfe863c62bfad78affa7084 (diff) | |
| download | qpid-python-e100648803b98ee2786475368ebd473945b96396.tar.gz | |
NO-JIRA: Add missing EXTERN declarations needed by HA module.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1355138 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src')
| -rw-r--r-- | cpp/src/qpid/broker/Connection.h | 16 |
1 files changed, 10 insertions, 6 deletions
diff --git a/cpp/src/qpid/broker/Connection.h b/cpp/src/qpid/broker/Connection.h index 97de44f94d..d01599ce54 100644 --- a/cpp/src/qpid/broker/Connection.h +++ b/cpp/src/qpid/broker/Connection.h @@ -27,8 +27,7 @@ #include <vector> #include <queue> -#include <boost/ptr_container/ptr_map.hpp> - +#include "qpid/broker/BrokerImportExport.h" #include "qpid/broker/ConnectionHandler.h" #include "qpid/broker/ConnectionState.h" #include "qpid/broker/SessionHandler.h" @@ -94,8 +93,14 @@ class Connection : public sys::ConnectionInputHandler, /** Get the SessionHandler for channel. Create if it does not already exist */ SessionHandler& getChannel(framing::ChannelId channel); - /** Close the connection */ - void close(framing::connection::CloseCode code, const std::string& text); + /** Close the connection. Waits for the client to respond with close-ok + * before actually destroying the connection. + */ + QPID_BROKER_EXTERN void close( + framing::connection::CloseCode code, const std::string& text); + + /** Abort the connection. Close abruptly and immediately. */ + QPID_BROKER_EXTERN void abort(); // ConnectionInputHandler methods void received(framing::AMQFrame& frame); @@ -139,8 +144,7 @@ class Connection : public sys::ConnectionInputHandler, void setHeartbeatInterval(uint16_t heartbeat); void sendHeartbeat(); void restartTimeout(); - void abort(); - + template <class F> void eachSessionHandler(F f) { for (ChannelMap::iterator i = channels.begin(); i != channels.end(); ++i) f(*ptr_map_ptr(i)); |