summaryrefslogtreecommitdiff
path: root/cpp/src/qpid/client/ConnectionImpl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/src/qpid/client/ConnectionImpl.cpp')
-rw-r--r--cpp/src/qpid/client/ConnectionImpl.cpp14
1 files changed, 4 insertions, 10 deletions
diff --git a/cpp/src/qpid/client/ConnectionImpl.cpp b/cpp/src/qpid/client/ConnectionImpl.cpp
index dbb0a67d22..056a53f263 100644
--- a/cpp/src/qpid/client/ConnectionImpl.cpp
+++ b/cpp/src/qpid/client/ConnectionImpl.cpp
@@ -149,16 +149,16 @@ IOThread& theIO() {
}
class HeartbeatTask : public TimerTask {
- TimeoutHandler& timeout;
+ ConnectionImpl& timeout;
void fire() {
// If we ever get here then we have timed out
QPID_LOG(debug, "Traffic timeout");
- timeout.idleIn();
+ timeout.timeout();
}
public:
- HeartbeatTask(Duration p, TimeoutHandler& t) :
+ HeartbeatTask(Duration p, ConnectionImpl& t) :
TimerTask(p,"Heartbeat"),
timeout(t)
{}
@@ -304,17 +304,11 @@ void ConnectionImpl::open()
}
}
-void ConnectionImpl::idleIn()
+void ConnectionImpl::timeout()
{
connector->abort();
}
-void ConnectionImpl::idleOut()
-{
- AMQFrame frame((AMQHeartbeatBody()));
- connector->handle(frame);
-}
-
void ConnectionImpl::close()
{
if (heartbeatTask)