Author: chirino
Date: Mon Apr 4 18:50:02 2011
New Revision: 1088716
URL: http://svn.apache.org/viewvc?rev=1088716&view=rev
Log:
Adding a toString method to queues of easier debugging.
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/QueueBinding.scala
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
URL:
http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala?rev=1088716&r1=1088715&r2=1088716&view=diff
==============================================================================
---
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
(original)
+++
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Queue.scala
Mon Apr 4 18:50:02 2011
@@ -30,6 +30,7 @@ import org.fusesource.hawtdispatch.{List
import OptionSupport._
import security.SecurityContext
import org.apache.activemq.apollo.dto.{DestinationDTO, QueueDTO}
+import java.lang.String
object Queue extends Log {
val subcsription_counter = new AtomicInteger(0)
@@ -46,6 +47,11 @@ import Queue._
*/
class Queue(val router: LocalRouter, val id:Long, val binding:QueueBinding,
var config:QueueDTO) extends BaseRetained with BindableDeliveryProducer with
DeliveryConsumer with BaseService with DomainDestination with Dispatched {
+ override def toString: String = {
+ "Queue(id:%d, binding:%s)".format(id, binding)
+ }
+
+
def virtual_host = router.virtual_host
var inbound_sessions = Set[DeliverySession]()
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/QueueBinding.scala
URL:
http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/QueueBinding.scala?rev=1088716&r1=1088715&r2=1088716&view=diff
==============================================================================
---
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/QueueBinding.scala
(original)
+++
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/QueueBinding.scala
Mon Apr 4 18:50:02 2011
@@ -23,6 +23,7 @@ import Buffer._
import org.apache.activemq.apollo.dto._
import org.apache.activemq.apollo.util.{OptionSupport, ClassFinder}
import org.apache.activemq.apollo.util.path.Path
+import java.lang.String
/**
* <p>
@@ -92,6 +93,8 @@ trait QueueBinding {
def destination:Path
def config(host:VirtualHost):QueueDTO
+
+ override def toString: String = label
}
object QueueDomainQueueBinding extends QueueBinding.Provider {
