summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/broker/Connection.h
diff options
context:
space:
mode:
authorGordon Sim <gsim@apache.org>2008-02-21 17:40:42 +0000
committerGordon Sim <gsim@apache.org>2008-02-21 17:40:42 +0000
commit3767d7e49e80c268c60ee247b3526b986eb7fc17 (patch)
tree36f0c9487e54705530be26271de7e52676bad524 /cpp/src/qpid/broker/Connection.h
parent5f06a953368f7f41dd8ab94a6775fcd9b5c99792 (diff)
downloadqpid-python-3767d7e49e80c268c60ee247b3526b986eb7fc17.tar.gz
Start moving towards final 0-10 spec:
* marked preview spec as 99-0 to distinguish it from 0-10 (which will now be used for the final version) * modified python client to treat 99-0 as 0-10 for now * modified broker to have two paths for the two different versions: 99-0 uses PreviewConnection, PreviewConnectionHandler and PreviewSessionHandler which are straight copy & pastes of the Connection, ConnectionHandler and SessionHandler now associated with 0-10 (so we can migrate the 0-10 path to the final spec without affecting clients working with the preview version) git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@629883 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/broker/Connection.h')
-rw-r--r--cpp/src/qpid/broker/Connection.h32
1 files changed, 2 insertions, 30 deletions
diff --git a/cpp/src/qpid/broker/Connection.h b/cpp/src/qpid/broker/Connection.h
index 99b394dda0..8719a9dfcd 100644
--- a/cpp/src/qpid/broker/Connection.h
+++ b/cpp/src/qpid/broker/Connection.h
@@ -39,6 +39,7 @@
#include "qpid/sys/Socket.h"
#include "qpid/Exception.h"
#include "ConnectionHandler.h"
+#include "ConnectionState.h"
#include "SessionHandler.h"
#include "qpid/management/Manageable.h"
#include "qpid/management/Client.h"
@@ -50,8 +51,7 @@ namespace qpid {
namespace broker {
class Connection : public sys::ConnectionInputHandler,
- public ConnectionToken,
- public management::Manageable
+ public ConnectionState
{
public:
Connection(sys::ConnectionOutputHandler* out, Broker& broker, const std::string& mgmtId);
@@ -63,25 +63,6 @@ class Connection : public sys::ConnectionInputHandler,
/** Close the connection */
void close(framing::ReplyCode code, const string& text, framing::ClassId classId, framing::MethodId methodId);
- sys::ConnectionOutputHandler& getOutput() const { return *out; }
- framing::ProtocolVersion getVersion() const { return version; }
-
- uint32_t getFrameMax() const { return framemax; }
- uint16_t getHeartbeat() const { return heartbeat; }
- uint64_t getStagingThreshold() const { return stagingThreshold; }
-
- void setFrameMax(uint32_t fm) { framemax = fm; }
- void setHeartbeat(uint16_t hb) { heartbeat = hb; }
- void setStagingThreshold(uint64_t st) { stagingThreshold = st; }
-
- Broker& getBroker() { return broker; }
-
- Broker& broker;
- std::vector<Queue::shared_ptr> exclusiveQueues;
-
- //contained output tasks
- sys::AggregateOutput outputTasks;
-
// ConnectionInputHandler methods
void received(framing::AMQFrame& frame);
void initiated(const framing::ProtocolInitiation& header);
@@ -98,9 +79,6 @@ class Connection : public sys::ConnectionInputHandler,
management::Manageable::status_t
ManagementMethod (uint32_t methodId, management::Args& args);
- void setUserId(const string& uid);
- const string& getUserId() const;
-
void initMgmt(bool asLink = false);
private:
@@ -126,17 +104,11 @@ class Connection : public sys::ConnectionInputHandler,
class MgmtClient;
class MgmtLink;
- framing::ProtocolVersion version;
ChannelMap channels;
- sys::ConnectionOutputHandler* out;
- uint32_t framemax;
- uint16_t heartbeat;
framing::AMQP_ClientProxy::Connection* client;
- uint64_t stagingThreshold;
ConnectionHandler adapter;
std::auto_ptr<MgmtWrapper> mgmtWrapper;
bool mgmtClosing;
- string userId;
const std::string mgmtId;
};