Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

apply threadName filter feature patch for AMQ-1993 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@710061 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Gary Tully 2008-11-03 14:22:48 +00:00
parent 46b5eb15fd
commit 0d2172bc9b
2 changed files with 69 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
activemq-core/src/main/java/org/apache/activemq/transport/ThreadNameFilter.java Normal file
View File

@ -0,0 +1,64 @@
/**
* Licensed to the Apache Software Foundation (ASF) under one or more
* contributor license agreements. See the NOTICE file distributed with
* this work for additional information regarding copyright ownership.
* The ASF licenses this file to You under the Apache License, Version 2.0
* (the "License"); you may not use this file except in compliance with
* the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.activemq.transport;
import java.io.IOException;
/**
* The thread name filter, modifies the name of the thread during the invocation to a transport.
* It appends the remote address, so that a call stuck in a transport method such as socketWrite0
* will have the destination information in the thread name.
* This is extremely useful for thread dumps when debugging.
* To enable this transport, in the transport URI, simpley add<br/>
* <code>transport.threadName</code>.<br/>
* For example:</br>
* <pre><code>
* &lt;transportConnector
* name=&quot;tcp1&quot;
* uri=&quot;tcp://127.0.0.1:61616?transport.soTimeout=10000&amp;transport.threadName"
* /&gt;
* </code></pre>
* @author Filip Hanik
*
*/
public class ThreadNameFilter extends TransportFilter {
public ThreadNameFilter(Transport next) {
super(next);
}
@Override
public void oneway(Object command) throws IOException {
String address =(next!=null?next.getRemoteAddress():null);
if (address!=null) {
String name = Thread.currentThread().getName();
try {
String sendname = name + " - SendTo:"+address;
Thread.currentThread().setName(sendname);
super.oneway(command);
}finally {
Thread.currentThread().setName(name);
}
} else {
super.oneway(command);
}
}
}

5
activemq-core/src/main/java/org/apache/activemq/transport/TransportFactory.java
View File

@ -44,6 +44,8 @@ public abstract class TransportFactory {
private static final FactoryFinder WIREFORMAT_FACTORY_FINDER = new FactoryFinder("META-INF/services/org/apache/activemq/wireformat/");
private static final ConcurrentHashMap<String, TransportFactory> TRANSPORT_FACTORYS = new ConcurrentHashMap<String, TransportFactory>();
private static final String THREAD_NAME_FILTER = "threadName";
public abstract TransportServer doBind(URI location) throws IOException;
public Transport doConnect(URI location, Executor ex) throws Exception {
@ -263,6 +265,9 @@ public abstract class TransportFactory {
* @throws Exception
*/
public Transport serverConfigure(Transport transport, WireFormat format, HashMap options) throws Exception {
if (options.containsKey(THREAD_NAME_FILTER)) {
transport = new ThreadNameFilter(transport);
}
transport = compositeConfigure(transport, format, options);
transport = new MutexTransport(transport);
return transport;