[PATCH 5/8] Rip out watchdog code, isn't used/needed

[Stan Lewis]

---
 .../apollo/stomp/perf/StompRemoteClients.scala     |   40 --------------------
 1 files changed, 0 insertions(+), 40 deletions(-)


diff --git a/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/perf/StompRemoteClients.scala b/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/perf/StompRemoteClients.scala
index 322c1ae..1b91d06 100644
--- a/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/perf/StompRemoteClients.scala
+++ b/apollo-stomp/src/test/scala/org/apache/activemq/apollo/stomp/perf/StompRemoteClients.scala
@@ -33,18 +33,6 @@ import _root_.org.fusesource.hawtdispatch.ScalaDispatch._
 class StompRemoteConsumer extends RemoteConsumer with Logging {
   var outboundSink: OverflowSink[StompFrame] = null
 
-  def watchdog(lastMessageCount: Int) : Unit = {
-    val seconds = 10
-    dispatchQueue.dispatchAfter(seconds, TimeUnit.SECONDS, ^ {
-          if (messageCount == lastMessageCount) {
-            warn("Messages have stopped arriving after " + seconds + "s, stopping consumer")
-            stop
-          } else {
-            watchdog(messageCount)
-          }
-        })
-  }
-
   def onConnected() = {
     outboundSink = new OverflowSink[StompFrame](MapSink(transportSink){ x=>x })
     outboundSink.refiller = ^{}
@@ -68,7 +56,6 @@ class StompRemoteConsumer extends RemoteConsumer with Logging {
 
     frame = StompFrame(SUBSCRIBE, headers);
     outboundSink.offer(frame);
-    watchdog(messageCount)
   }
 
   override def onTransportCommand(command: Object) = {
@@ -185,30 +172,3 @@ class StompRemoteProducer extends RemoteProducer with Logging {
   }
 }
 
-trait Watchog extends RemoteConsumer {
-  var messageCount = 0
-
-  def watchdog(lastMessageCount: Int): Unit = {
-    val seconds = 10
-    dispatchQueue.dispatchAfter(seconds, TimeUnit.SECONDS, ^ {
-      if (messageCount == lastMessageCount) {
-        warn("Messages have stopped arriving after " + seconds + "s, stopping consumer")
-        stop
-      } else {
-        watchdog(messageCount)
-      }
-    })
-  }
-
-  abstract override protected def messageReceived() = {
-    super.messageReceived
-    messageCount += 1
-  }
-
-  abstract override protected def onConnected() = {
-    super.onConnected
-    watchdog(messageCount)
-  }
-
-}
-