You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ch...@apache.org on 2011/05/27 20:14:06 UTC
svn commit: r1128414 -
/activemq/activemq-apollo/trunk/apollo-stomp/src/main/scala/org/apache/activemq/apollo/stomp/StompProtocolHandler.scala
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