public final class IncomingConnectionFactory extends EventHandler implements ConnectionI.StartCallback
_disabled, _hasMoreData, _key, _registered| Constructor and Description |
|---|
IncomingConnectionFactory(Instance instance,
EndpointI endpoint,
ObjectAdapterI adapter) |
| Modifier and Type | Method and Description |
|---|---|
void |
activate() |
java.util.LinkedList<ConnectionI> |
connections() |
void |
connectionStartCompleted(ConnectionI connection) |
void |
connectionStartFailed(ConnectionI connection,
LocalException ex) |
void |
destroy() |
EndpointI |
endpoint() |
java.nio.channels.SelectableChannel |
fd() |
protected void |
finalize() |
void |
finished(ThreadPoolCurrent current,
boolean close) |
void |
flushAsyncBatchRequests(CommunicatorFlushBatch outAsync) |
void |
hold() |
void |
message(ThreadPoolCurrent current) |
java.lang.String |
toString() |
void |
updateConnectionObservers() |
void |
waitUntilFinished() |
void |
waitUntilHolding() |
public IncomingConnectionFactory(Instance instance, EndpointI endpoint, ObjectAdapterI adapter)
public void activate()
public void hold()
public void destroy()
public void updateConnectionObservers()
public void waitUntilHolding()
throws java.lang.InterruptedException
java.lang.InterruptedExceptionpublic void waitUntilFinished()
throws java.lang.InterruptedException
java.lang.InterruptedExceptionpublic EndpointI endpoint()
public java.util.LinkedList<ConnectionI> connections()
public void flushAsyncBatchRequests(CommunicatorFlushBatch outAsync)
public void message(ThreadPoolCurrent current)
message in class EventHandlerpublic void finished(ThreadPoolCurrent current, boolean close)
finished in class EventHandlerpublic java.lang.String toString()
toString in class EventHandlerpublic java.nio.channels.SelectableChannel fd()
fd in class EventHandlerpublic void connectionStartCompleted(ConnectionI connection)
connectionStartCompleted in interface ConnectionI.StartCallbackpublic void connectionStartFailed(ConnectionI connection, LocalException ex)
connectionStartFailed in interface ConnectionI.StartCallbackprotected void finalize()
throws java.lang.Throwable
finalize in class java.lang.Objectjava.lang.Throwable