activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1220420 - in /activemq/activemq-apollo/trunk: apollo-openwire/src/main/scala/org/apache/activemq/apollo/openwire/OpenwireProtocolHandler.scala apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
Date Sun, 18 Dec 2011 15:07:10 GMT
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)
             })



Mime
View raw message