public class LocalConnector.LocalEndPoint extends ByteArrayEndPoint
| Constructor and Description |
|---|
LocalEndPoint() |
| Modifier and Type | Method and Description |
|---|---|
void |
doShutdownOutput() |
protected void |
execute(Runnable task) |
void |
onClose()
Callback method invoked when this
EndPoint is close. |
ByteBuffer |
waitForResponse(boolean head,
long time,
TimeUnit unit)
Wait for a response using a parser to detect the end of message
|
void |
waitUntilClosed() |
void |
waitUntilClosedOrIdleFor(long idleFor,
TimeUnit units) |
addInput, addInput, addInput, addInputAndExecute, addInputEOF, fill, flush, getLocalAddress, getOutput, getOutputString, getOutputString, getRemoteAddress, getTransport, hasMore, isGrowOutput, needsFillInterest, onIncompleteFlush, reset, setGrowOutput, setOutput, takeOutput, takeOutputString, takeOutputString, waitForOutputcheckFill, checkFlush, close, close, doClose, doShutdownInput, fillInterested, getConnection, getCreatedTimeStamp, getFillInterest, getWriteFlusher, isFillInterested, isInputShutdown, isOpen, isOptimizedForDirectBuffers, isOutputShutdown, onClose, onIdleExpired, onOpen, setConnection, shutdownInput, shutdownOutput, toString, upgrade, writecheckIdleTimeout, getIdleFor, getIdleTimeout, getIdleTimestamp, getScheduler, notIdle, setIdleTimeoutclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetIdleTimeout, setIdleTimeoutprotected void execute(Runnable task)
execute in class ByteArrayEndPointpublic void onClose()
EndPointCallback method invoked when this EndPoint is close.
onClose in interface EndPointonClose in class AbstractEndPointEndPoint.onOpen()public void doShutdownOutput()
doShutdownOutput in class AbstractEndPointpublic void waitUntilClosed()
public void waitUntilClosedOrIdleFor(long idleFor,
TimeUnit units)
public ByteBuffer waitForResponse(boolean head, long time, TimeUnit unit) throws Exception
head - time - unit - ExceptionCopyright © 1995–2016 Mort Bay Consulting. All rights reserved.