activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From chir...@apache.org
Subject svn commit: r1128414 - /activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
Date Fri, 27 May 2011 18:14:06 GMT
Author: chirino
Date: Fri May 27 18:14:06 2011
New Revision: 1128414

URL: http://svn.apache.org/viewvc?rev=1128414&view=rev
Log:
Comment out the debugging logic again.

Modified:
    activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala

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=1128414&r1=1128413&r2=1128414&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
Fri May 27 18:14:06 2011
@@ -224,31 +224,30 @@ class StompProtocolHandler extends Proto
     val selector:(String, BooleanExpression),
     override val browser:Boolean,
     override val exclusive:Boolean
-  ) extends Retained with DeliveryConsumer {
-//  ) extends BaseRetained with DeliveryConsumer {
+  ) extends BaseRetained with DeliveryConsumer {
 
 ////  The following comes in handy if we need to debug the
 ////  reference counts of the consumers.
 //
-    val r = new BaseRetained
-
-    def setDisposer(p1: Runnable): Unit = r.setDisposer(p1)
-    def retained: Int =r.retained
-
-    def printST(name:String) = {
-      val e = new Exception
-      println(name+": ")
-      println("  "+e.getStackTrace.drop(1).take(4).mkString("\n  "))
-    }
-
-    def retain: Unit = {
-      printST("retain")
-      r.retain
-    }
-    def release: Unit = {
-      printST("release")
-      r.release
-    }
+//    val r = new BaseRetained
+//
+//    def setDisposer(p1: Runnable): Unit = r.setDisposer(p1)
+//    def retained: Int =r.retained
+//
+//    def printST(name:String) = {
+//      val e = new Exception
+//      println(name+": ")
+//      println("  "+e.getStackTrace.drop(1).take(4).mkString("\n  "))
+//    }
+//
+//    def retain: Unit = {
+//      printST("retain")
+//      r.retain
+//    }
+//    def release: Unit = {
+//      printST("release")
+//      r.release
+//    }
 
     val dispatch_queue = StompProtocolHandler.this.dispatchQueue
 



Mime
View raw message