Author: chirino
Date: Fri Nov 5 22:12:27 2010
New Revision: 1031847
URL: http://svn.apache.org/viewvc?rev=1031847&view=rev
Log:
Assign a label to the connection's dispatch queue.
Modified:
activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Connector.scala
Modified: activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Connector.scala
URL: http://svn.apache.org/viewvc/activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Connector.scala?rev=1031847&r1=1031846&r2=1031847&view=diff
==============================================================================
--- activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Connector.scala
(original)
+++ activemq/activemq-apollo/trunk/apollo-broker/src/main/scala/org/apache/activemq/apollo/broker/Connector.scala
Fri Nov 5 22:12:27 2010
@@ -99,6 +99,7 @@ class Connector(val broker:Broker, val i
accept_counter.incrementAndGet
var connection = new BrokerConnection(Connector.this, broker.connection_id_counter.incrementAndGet)
+ connection.dispatchQueue.setLabel("connection %d to %s".format(connection.id, transport.getRemoteAddress))
connection.protocolHandler = protocol.createProtocolHandler
connection.transport = transport
|