Filter implementation, which should work with any Transport. This Filter tries to
delegate I/O event processing to the Transport's specific transport Filter. If Transport
doesn't have own implementation - uses common I/O event processing logic.
TransportFilter could be set to work in 2 modes: stream or message. In
stream mode, TransportFilter produces/consumes the socket channel directly.
In message mode, TransportFilter represents Connection data as Buffer, using
FilterChainContext#getMessage()}, FilterChainContext#setMessage(Object).
For specific Transport, one mode could be more preferable than another. For example TCPNIOTransport
works just in stream mode. UDPNIOTransport prefers message mode, but could also
work in stream mode.
| Modifier and Type | Class and Description |
|---|---|
| public static class |
| Modifier and Type | Field and Description |
|---|---|
| private static final TransportFilter. | FLUSH_EVENT
TransportFilter flush command event |
| Access | Constructor and Description |
|---|---|
| public |
| FLUSH_EVENT | back to summary |
|---|---|
| private static final TransportFilter. TransportFilter flush command event | |
| TransportFilter | back to summary |
|---|---|
| public TransportFilter() Create TransportFilter. | |
| createFlushEvent | back to summary |
|---|---|
public static FilterChainEvent createFlushEvent()
| |
| createFlushEvent | back to summary |
|---|---|
| public static FilterChainEvent createFlushEvent(final CompletionHandler<E> completionHandler) | |
| exceptionOccurred | back to summary |
|---|---|
| public void exceptionOccurred(FilterChainContext ctx, Throwable error) Overrides org. Implements org. Delegates exception operation to
| |
| getTransportFilter0 | back to summary |
|---|---|
| protected Filter getTransportFilter0(final Transport transport) Get default | |
| handleAccept | back to summary |
|---|---|
| public NextAction handleAccept(final FilterChainContext ctx) throws IOException Overrides org. Implements org. Delegates accept operation to
| |
| handleClose | back to summary |
|---|---|
| public NextAction handleClose(final FilterChainContext ctx) throws IOException Overrides org. Implements org. Delegates close operation to
| |
| handleConnect | back to summary |
|---|---|
| public NextAction handleConnect(final FilterChainContext ctx) throws IOException Overrides org. Implements org. Delegates connect operation to
| |
| handleEvent | back to summary |
|---|---|
| public NextAction handleEvent(final FilterChainContext ctx, final FilterChainEvent event) throws IOException Overrides org. Implements org. Delegates event operation to
| |
| handleRead | back to summary |
|---|---|
| public NextAction handleRead(final FilterChainContext ctx) throws IOException Overrides org. Implements org. Delegates reading operation to
| |
| handleWrite | back to summary |
|---|---|
| public NextAction handleWrite(final FilterChainContext ctx) throws IOException Overrides org. Implements org. Delegates writing operation to
| |
| Modifier and Type | Field and Description |
|---|---|
| pack-priv final CompletionHandler | |
| public static final Object |
| Access | Constructor and Description |
|---|---|
| private | |
| private |
| Modifier and Type | Method and Description |
|---|---|
| public CompletionHandler | |
| public Object |
| completionHandler | back to summary |
|---|---|
| pack-priv final CompletionHandler<E> completionHandler | |
| TYPE | back to summary |
|---|---|
| public static final Object TYPE | |
| FlushEvent | back to summary |
|---|---|
| private FlushEvent() | |
| FlushEvent | back to summary |
|---|---|
| private FlushEvent(final CompletionHandler<E> completionHandler) | |
| getCompletionHandler | back to summary |
|---|---|
| public CompletionHandler | |
| type | back to summary |
|---|---|
| public Object type() Implements org.
| |