diff options
Diffstat (limited to 'qpid/java/client/src/main/java/org/apache/qpid/client/transport/ClientConnectionDelegate.java')
-rw-r--r-- | qpid/java/client/src/main/java/org/apache/qpid/client/transport/ClientConnectionDelegate.java | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/transport/ClientConnectionDelegate.java b/qpid/java/client/src/main/java/org/apache/qpid/client/transport/ClientConnectionDelegate.java index e9b946d5b7..51354a5941 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/transport/ClientConnectionDelegate.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/transport/ClientConnectionDelegate.java @@ -179,12 +179,9 @@ public class ClientConnectionDelegate extends ClientDelegate } @Override - public void connectionHeartbeat(Connection conn, ConnectionHeartbeat hearbeat) + public void connectionHeartbeat(Connection conn, ConnectionHeartbeat heartbeat) { - // ClientDelegate simply responds to heartbeats with heartbeats _heartbeatListener.heartbeatReceived(); - super.connectionHeartbeat(conn, hearbeat); - _heartbeatListener.heartbeatSent(); } @@ -192,4 +189,11 @@ public class ClientConnectionDelegate extends ClientDelegate { _heartbeatListener = listener == null ? HeartbeatListener.DEFAULT : listener; } + + @Override + public void writerIdle(final Connection connection) + { + super.writerIdle(connection); + _heartbeatListener.heartbeatSent(); + } } |