From 15488eba1c867bac8b6db1f7ad870b277c4fa748 Mon Sep 17 00:00:00 2001 From: "Rafael H. Schloming" Date: Tue, 20 Jan 2009 21:21:31 +0000 Subject: QPID-1603: ignore incoming heartbeat controls git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@736109 13f79535-47bb-0310-9956-ffa450edef68 --- .../main/java/org/apache/qpid/transport/ConnectionDelegate.java | 5 +++++ .../src/test/java/org/apache/qpid/transport/ConnectionTest.java | 9 +++++++++ 2 files changed, 14 insertions(+) (limited to 'java/common') diff --git a/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java b/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java index a1e3dee024..9ef7a47e1b 100644 --- a/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java +++ b/java/common/src/main/java/org/apache/qpid/transport/ConnectionDelegate.java @@ -64,6 +64,11 @@ public abstract class ConnectionDelegate conn.dispatch(method); } + @Override public void connectionHeartbeat(Connection conn, ConnectionHeartbeat hearbeat) + { + // do nothing + } + @Override public void connectionClose(Connection conn, ConnectionClose close) { conn.connectionCloseOk(); diff --git a/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java b/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java index 7ce41db4d0..dca6264367 100644 --- a/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java +++ b/java/common/src/test/java/org/apache/qpid/transport/ConnectionTest.java @@ -382,4 +382,13 @@ public class ConnectionTest extends TestCase implements SessionListener ssn.sync(); } + public void testHeartbeat() + { + startServer(); + Connection conn = new Connection(); + conn.connect("localhost", port, null, "guest", "guest"); + conn.connectionHeartbeat(); + conn.close(); + } + } -- cgit v1.2.1