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 AtomicInteger |
messageCounter |
protected static long |
sleep |
protected static WriteTimeoutFilter.TimeoutThread |
timeoutThread |
protected static 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,
IOException iox) |
static long |
getSleep() |
protected Socket |
getSocket() |
protected TimeStampStream |
getWriter() |
long |
getWriteTimeout() |
void |
oneway(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 ConcurrentLinkedQueue<WriteTimeoutFilter> writers
protected static AtomicInteger messageCounter
protected static WriteTimeoutFilter.TimeoutThread timeoutThread
protected static long sleep
protected long writeTimeout
public WriteTimeoutFilter(Transport next)
public void oneway(Object command) throws IOException
Transport
oneway
in interface Transport
oneway
in class TransportFilter
IOException
public long getWriteTimeout()
public void setWriteTimeout(long writeTimeout)
public static long getSleep()
public static void setSleep(long sleep)
protected TimeStampStream getWriter()
protected static void registerWrite(WriteTimeoutFilter filter)
protected static boolean deRegisterWrite(WriteTimeoutFilter filter, boolean fail, IOException iox)
public void start() throws Exception
start
in interface Service
start
in class TransportFilter
Exception
Service.start()
public void stop() throws Exception
stop
in interface Service
stop
in class TransportFilter
Exception
Service.stop()
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.