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
