public class WriteTimeoutFilter extends TransportFilter
transport.soWriteTimeout=
.
<transportConnector
name="tcp1"
uri="tcp://127.0.0.1:61616?transport.soTimeout=10000&transport.soWriteTimeout=15000"
/>
<transportConnector
name="tcp1"
uri="tcp://127.0.0.1:61616?transport.soTimeout=10000&transport.soWriteTimeout=15000"
/>
Modifier and Type | Class and Description |
---|---|
protected static class |
WriteTimeoutFilter.TimeoutThread |
Modifier and Type | Field and Description |
---|---|
protected static java.util.concurrent.atomic.AtomicInteger |
messageCounter |
protected static long |
sleep |
protected static WriteTimeoutFilter.TimeoutThread |
timeoutThread |
protected static java.util.concurrent.ConcurrentLinkedQueue<WriteTimeoutFilter> |
writers |
protected long |
writeTimeout |
next, transportListener
Constructor and Description |
---|
WriteTimeoutFilter(Transport next) |
Modifier and Type | Method and Description |
---|---|
protected static boolean |
deRegisterWrite(WriteTimeoutFilter filter,
boolean fail,
java.io.IOException iox) |
static long |
getSleep() |
protected java.net.Socket |
getSocket() |
protected TimeStampStream |
getWriter() |
long |
getWriteTimeout() |
void |
oneway(java.lang.Object command)
A one way asynchronous send
|
protected static void |
registerWrite(WriteTimeoutFilter filter) |
static void |
setSleep(long sleep) |
void |
setWriteTimeout(long writeTimeout) |
void |
start() |
void |
stop() |
asyncRequest, getNext, getReceiveCounter, getRemoteAddress, getTransportListener, isConnected, isDisposed, isFaultTolerant, isReconnectSupported, isUpdateURIsSupported, narrow, onCommand, onException, reconnect, request, request, setTransportListener, toString, transportInterupted, transportResumed, updateURIs
protected static java.util.concurrent.ConcurrentLinkedQueue<WriteTimeoutFilter> writers
protected static java.util.concurrent.atomic.AtomicInteger messageCounter
protected static WriteTimeoutFilter.TimeoutThread timeoutThread
protected static long sleep
protected long writeTimeout
public WriteTimeoutFilter(Transport next)
public void oneway(java.lang.Object command) throws java.io.IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
java.io.IOException
public long getWriteTimeout()
public void setWriteTimeout(long writeTimeout)
public static long getSleep()
public static void setSleep(long sleep)
protected TimeStampStream getWriter()
protected java.net.Socket getSocket()
protected static void registerWrite(WriteTimeoutFilter filter)
protected static boolean deRegisterWrite(WriteTimeoutFilter filter, boolean fail, java.io.IOException iox)
public void start() throws java.lang.Exception
start
in interface Service
start
in class TransportFilter
java.lang.Exception
Service.start()
public void stop() throws java.lang.Exception
stop
in interface Service
stop
in class TransportFilter
java.lang.Exception
Service.stop()
Copyright © 2005-2017. All Rights Reserved.