summaryrefslogtreecommitdiff
path: root/qpid/java/common/src/main/java/org/apache
diff options
context:
space:
mode:
authorRobert Gemmell <robbie@apache.org>2010-09-26 22:34:40 +0000
committerRobert Gemmell <robbie@apache.org>2010-09-26 22:34:40 +0000
commitb89747e29966e0d78e59974ae54ee5ee5a91c669 (patch)
treefad927fdc1462eb7648b70f57b04d0d05a84339a /qpid/java/common/src/main/java/org/apache
parent495b52eb246d1899f3d72c63367dc8099ac1dc32 (diff)
downloadqpid-python-b89747e29966e0d78e59974ae54ee5ee5a91c669.tar.gz
QPID-2872: make the broker indicate a heartbeat max of 0sec to cause the client disable heartbeating, as it otherwise enables the connection idle timeout by default and the broker cant generate them.
Needed until QPID-2796 is undertaken to implement broker support for generating heartbeats. git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1001544 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/common/src/main/java/org/apache')
-rw-r--r--qpid/java/common/src/main/java/org/apache/qpid/transport/ServerDelegate.java7
1 files changed, 6 insertions, 1 deletions
diff --git a/qpid/java/common/src/main/java/org/apache/qpid/transport/ServerDelegate.java b/qpid/java/common/src/main/java/org/apache/qpid/transport/ServerDelegate.java
index 5af2d4d1b3..3bd5c7fe0d 100644
--- a/qpid/java/common/src/main/java/org/apache/qpid/transport/ServerDelegate.java
+++ b/qpid/java/common/src/main/java/org/apache/qpid/transport/ServerDelegate.java
@@ -117,7 +117,7 @@ public class ServerDelegate extends ConnectionDelegate
conn.connectionTune
(Integer.MAX_VALUE,
org.apache.qpid.transport.network.ConnectionBinding.MAX_FRAME_SIZE,
- 0, Integer.MAX_VALUE);
+ 0, getHeartbeatMax());
conn.setAuthorizationID(ss.getAuthorizationID());
}
else
@@ -132,6 +132,11 @@ public class ServerDelegate extends ConnectionDelegate
}
}
+ protected int getHeartbeatMax()
+ {
+ return Integer.MAX_VALUE;
+ }
+
@Override public void connectionSecureOk(Connection conn, ConnectionSecureOk ok)
{
secure(conn, ok.getResponse());