summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/RdmaConnector.cpp
diff options
context:
space:
mode:
authorAndrew Stitcher <astitcher@apache.org>2013-06-10 19:46:43 +0000
committerAndrew Stitcher <astitcher@apache.org>2013-06-10 19:46:43 +0000
commite178b460ca36b830b4fd9957f556226e61b9747b (patch)
treefca5ae058bd2090e7d9ae691eb6bbb662eda23d2 /cpp/src/qpid/client/RdmaConnector.cpp
parent8bb04cee8094c1956107435081089b1e2e13688d (diff)
downloadqpid-python-e178b460ca36b830b4fd9957f556226e61b9747b.tar.gz
QPID-4905: Tidy-up remove OutputHandler and directly use FrameHandler
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1491580 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/src/qpid/client/RdmaConnector.cpp')
-rw-r--r--cpp/src/qpid/client/RdmaConnector.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/cpp/src/qpid/client/RdmaConnector.cpp b/cpp/src/qpid/client/RdmaConnector.cpp
index 618fcf9e0b..1689b7aee2 100644
--- a/cpp/src/qpid/client/RdmaConnector.cpp
+++ b/cpp/src/qpid/client/RdmaConnector.cpp
@@ -70,7 +70,7 @@ class RdmaConnector : public Connector, public sys::Codec
sys::ShutdownHandler* shutdownHandler;
framing::InputHandler* input;
framing::InitiationHandler* initialiser;
- framing::OutputHandler* output;
+ framing::FrameHandler* output;
Rdma::AsynchIO* aio;
Rdma::Connector* acon;
@@ -97,7 +97,7 @@ class RdmaConnector : public Connector, public sys::Codec
void connect(const std::string& host, const std::string& port);
void close();
- void send(framing::AMQFrame& frame);
+ void handle(framing::AMQFrame& frame);
void abort() {} // TODO: need to fix this for heartbeat timeouts to work
void setInputHandler(framing::InputHandler* handler);
@@ -312,7 +312,7 @@ const std::string& RdmaConnector::getIdentifier() const {
return identifier;
}
-void RdmaConnector::send(AMQFrame& frame) {
+void RdmaConnector::handle(AMQFrame& frame) {
// It is possible that we are called to write after we are already shutting down
Mutex::ScopedLock l(dataConnectedLock);
if (!dataConnected) return;