Author: chirino
Date: Sun Dec 18 15:07:09 2011
New Revision: 1220420
URL: http://svn.apache.org/viewvc?rev=1220420&view=rev
Log:
Monitor writes at /2 the interval.
Modified:
activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala
activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
Modified:
activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala
URL:
http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala?rev=1220420&r1=1220419&r2=1220420&view=diff
==============================================================================
---
activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala
(original)
+++
activemq/activemq-apollo/trunk/apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala
Sun Dec 18 15:07:09 2011
@@ -392,7 +392,7 @@ class OpenwireProtocolHandler extends Pr
async_die("Stale connection. Missed heartbeat.")
})
- heart_beat_monitor.setWriteInterval(inactive_time)
+ heart_beat_monitor.setWriteInterval(inactive_time / 2)
heart_beat_monitor.setOnKeepAlive(^{
// we don't care if the offer gets rejected.. since that just
// means there is other traffic getting transmitted.
Modified:
activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
URL:
http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala?rev=1220420&r1=1220419&r2=1220420&view=diff
==============================================================================
---
activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
(original)
+++
activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
Sun Dec 18 15:07:09 2011
@@ -843,7 +843,7 @@ class StompProtocolHandler extends Proto
});
}
if( outbound_heartbeat>=0 && please_send > 0 ) {
-
heart_beat_monitor.setWriteInterval(outbound_heartbeat.max(please_send))
+
heart_beat_monitor.setWriteInterval(outbound_heartbeat.max(please_send)/2)
heart_beat_monitor.setOnKeepAlive(^{
connection.transport.offer(NEWLINE_BUFFER)
})
