| Modifier and Type | Class and Description |
|---|---|
| private static class | |
| private class | |
| private class |
| Modifier and Type | Field and Description |
|---|---|
| private final BackChannelFilter | |
| private final boolean | |
| private static final Logger | |
| private final ArraySet | |
| pack-priv final Attribute | |
| pack-priv final Attribute | |
| private final PUFilter. |
| Access | Constructor and Description |
|---|---|
| public | |
| public | PUFilter(final boolean
true if a isCloseUnrecognizedConnection)Connection whose protocol is not recognized will be
automatically closed, or false if normal FilterChain processing will be continued for such
Connection, so a Filter next to PUFilter may implement custom logic to process unrecognized
connection.Constructs PUFilter. |
| Modifier and Type | Method and Description |
|---|---|
| public void | |
| protected void | |
| public Filter | Returns: back channelFilter.Get the back channel |
| public Set | |
| public FilterChainBuilder | Returns: FilterChainBuilder.Returns the |
| public NextAction | handleClose(FilterChainContext ctx)
Overrides org. Implements org. Execute a unit of processing work to be performed, when connection has been closed. |
| public NextAction | handleEvent(final FilterChainContext ctx, final FilterChainEvent event)
Overrides org. Implements org. Handle custom event associated with the |
| public NextAction | handleRead(final FilterChainContext ctx)
Overrides org. Implements org. Execute a unit of processing work to be performed, when channel will become available for reading. |
| public boolean | isCloseUnrecognizedConnection()
Returns true if a |
| private static boolean | |
| private FilterChainContext | obtainChildFilterChainContext(final PUProtocol protocol, final Connection<L> connection, final FilterChainContext ctx)
|
| public PUProtocol | register(final ProtocolFinder protocolFinder, final FilterChain filterChain)
Registers new |
| public void |
| backChannelFilter | back to summary |
|---|---|
| private final BackChannelFilter backChannelFilter | |
| isCloseUnrecognizedConnection | back to summary |
|---|---|
| private final boolean isCloseUnrecognizedConnection | |
| LOGGER | back to summary |
|---|---|
| private static final Logger LOGGER | |
| protocols | back to summary |
|---|---|
| private final ArraySet<PUProtocol> protocols | |
| puContextAttribute | back to summary |
|---|---|
| pack-priv final Attribute<PUContext> puContextAttribute | |
| suspendedContextAttribute | back to summary |
|---|---|
| pack-priv final Attribute<FilterChainContext> suspendedContextAttribute | |
| suspendedContextCopyListener | back to summary |
|---|---|
| private final PUFilter. | |
| PUFilter | back to summary |
|---|---|
| public PUFilter() | |
| PUFilter | back to summary |
|---|---|
| public PUFilter(final boolean isCloseUnrecognizedConnection) Constructs PUFilter.
| |
| deregister | back to summary |
|---|---|
| public void deregister(final PUProtocol puProtocol) Deregisters the
| |
| findProtocol | back to summary |
|---|---|
| protected void findProtocol(final PUContext puContext, final FilterChainContext ctx) | |
| getBackChannelFilter | back to summary |
|---|---|
| public Filter getBackChannelFilter() Get the back channel | |
| getProtocols | back to summary |
|---|---|
| public Set Get registered port unification protocols -
| |
| getPUFilterChainBuilder | back to summary |
|---|---|
| public FilterChainBuilder getPUFilterChainBuilder() Returns the
| |
| handleClose | back to summary |
|---|---|
| public NextAction handleClose(FilterChainContext ctx) throws IOException Overrides org. Implements org. Doc from org. Execute a unit of processing work to be performed, when connection has been closed. This
| |
| handleEvent | back to summary |
|---|---|
| public NextAction handleEvent(final FilterChainContext ctx, final FilterChainEvent event) throws IOException Overrides org. Implements org. Doc from org. Handle custom event associated with the
| |
| handleRead | back to summary |
|---|---|
| public NextAction handleRead(final FilterChainContext ctx) throws IOException Overrides org. Implements org. Doc from org. Execute a unit of processing work to be performed, when channel will become available for reading. This
| |
| isCloseUnrecognizedConnection | back to summary |
|---|---|
| public boolean isCloseUnrecognizedConnection() Returns true if a | |
| isUpstream | back to summary |
|---|---|
| private static boolean isUpstream(final FilterChainContext context) | |
| obtainChildFilterChainContext | back to summary |
|---|---|
| private FilterChainContext obtainChildFilterChainContext(final PUProtocol protocol, final Connection<L> connection, final FilterChainContext ctx) | |
| register | back to summary |
|---|---|
| public PUProtocol register(final ProtocolFinder protocolFinder, final FilterChain filterChain) Registers new
| |
| register | back to summary |
|---|---|
| public void register(final PUProtocol puProtocol) Registers new
| |
| Modifier and Type | Field and Description |
|---|---|
| private final FilterChainContext |
| Access | Constructor and Description |
|---|---|
| public |
| Modifier and Type | Method and Description |
|---|---|
| public void | cancelled()
Implements org. The operation was cancelled. |
| public void | completed(final FilterChainContext context)
Implements org. The operation was completed. |
| public void | failed(final Throwable throwable)
Implements org. The operation was failed. |
| public void | updated(FilterChainContext result)
Implements org. The callback method may be called, when there is some progress in operation execution, but it is still not completed |
| suspendedContext | back to summary |
|---|---|
| private final FilterChainContext suspendedContext | |
| InternalCompletionHandler | back to summary |
|---|---|
| public InternalCompletionHandler(FilterChainContext suspendedContext) | |
| cancelled | back to summary |
|---|---|
| public void cancelled() Implements org. Doc from org. The operation was cancelled.
| |
| completed | back to summary |
|---|---|
| public void completed(final FilterChainContext context) Implements org. Doc from org. The operation was completed.
| |
| failed | back to summary |
|---|---|
| public void failed(final Throwable throwable) Implements org. Doc from org. The operation was failed.
| |
| updated | back to summary |
|---|---|
| public void updated(FilterChainContext result) Implements org. Doc from org. The callback method may be called, when there is some progress in operation execution, but it is still not completed
| |
| Modifier and Type | Field and Description |
|---|---|
| private final FilterChainContext |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | onComplete(final Context context, final Object data)
Overrides org. Implements org.
|
| public void | onReregister(final Context context)
Overrides org. Implements org. Reregister |
| parentContext | back to summary |
|---|---|
| private final FilterChainContext parentContext | |
| InternalProcessingHandler | back to summary |
|---|---|
| private InternalProcessingHandler(final FilterChainContext parentContext) | |
| onComplete | back to summary |
|---|---|
| public void onComplete(final Context context, final Object data) throws IOException Overrides org. Implements org. Doc from org.
| |
| onReregister | back to summary |
|---|---|
| public void onReregister(final Context context) throws IOException Overrides org. Implements org. Doc from org. Reregister
| |
| Access | Constructor and Description |
|---|---|
| private |
| Modifier and Type | Method and Description |
|---|---|
| public void | onCopy(final FilterChainContext srcContext, final FilterChainContext copiedContext)
Implements org. The method is called, when passed |
| SuspendedContextCopyListener | back to summary |
|---|---|
| private SuspendedContextCopyListener() | |
| onCopy | back to summary |
|---|---|
| public void onCopy(final FilterChainContext srcContext, final FilterChainContext copiedContext) Implements org. Doc from org. The method is called, when passed
| |