org.apache.activemq.transport
Class ThreadNameFilter
java.lang.Object
org.apache.activemq.transport.TransportFilter
org.apache.activemq.transport.ThreadNameFilter
- All Implemented Interfaces:
- Service, Transport, TransportListener
public class ThreadNameFilter
- extends TransportFilter
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
transport.threadName
.
For example:
<transportConnector
name="tcp1"
uri="tcp://127.0.0.1:61616?transport.soTimeout=10000&transport.threadName"
/>
- Author:
- Filip Hanik
Method Summary |
void |
oneway(java.lang.Object command)
A one way asynchronous send |
Methods inherited from class org.apache.activemq.transport.TransportFilter |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onCommand, onException, reconnect, request, request, setTransportListener, start, stop, toString, transportInterupted, transportResumed, updateURIs |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
ThreadNameFilter
public ThreadNameFilter(Transport next)
oneway
public void oneway(java.lang.Object command)
throws java.io.IOException
- Description copied from interface:
Transport
- A one way asynchronous send
- Specified by:
oneway
in interface Transport
- Overrides:
oneway
in class TransportFilter
- Throws:
java.io.IOException
Copyright © 2005-2016. All Rights Reserved.