Author: orudyy
Date: Fri Nov 13 12:16:13 2015
New Revision: 1714195
URL: http://svn.apache.org/viewvc?rev=1714195&view=rev
Log:
QPID-6846: Disable IdleTimeoutTicker for AMQP 1.0 until heartbeating is fully
implemented
Modified:
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Connection_1_0.java
Modified:
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Connection_1_0.java
URL:
http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Connection_1_0.java?rev=1714195&r1=1714194&r2=1714195&view=diff
==============================================================================
---
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Connection_1_0.java
(original)
+++
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/Connection_1_0.java
Fri Nov 13 12:16:13 2015
@@ -139,6 +139,10 @@ public class Connection_1_0 implements C
}
_amqpConnection.setClientId(_connectionEndpoint.getRemoteContainerId());
}
+ // TODO implement AMQP 1.0 heartbeating
+ _amqpConnection.getNetwork().setMaxReadIdle(0);
+ _amqpConnection.getNetwork().setMaxWriteIdle(0);
+
_vhost = ((AmqpPort)_port).getVirtualHost(host);
if(_vhost == null)
{
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
