@Internal public class ServerH2StreamMultiplexer extends Object
ProtocolIOSession that implements
server side HTTP/2 messaging protocol with full support for
multiplexed message transmission.| Constructor and Description |
|---|
ServerH2StreamMultiplexer(ProtocolIOSession ioSession,
FrameFactory frameFactory,
HttpProcessor httpProcessor,
HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory,
CharCodingConfig charCodingConfig,
H2Config h2Config,
H2StreamListener streamListener) |
ServerH2StreamMultiplexer(ProtocolIOSession ioSession,
HttpProcessor httpProcessor,
HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory,
CharCodingConfig charCodingConfig,
H2Config h2Config) |
| Modifier and Type | Method and Description |
|---|---|
void |
close()
Closes this connection gracefully.
|
void |
close(CloseMode closeMode)
Closes this process or endpoint and releases any system resources associated
with it.
|
EndpointDetails |
getEndpointDetails()
Returns this connection's endpoint details.
|
String |
getId() |
SocketAddress |
getLocalAddress()
Returns this connection's local address or
null if it is not bound yet. |
ProtocolVersion |
getProtocolVersion()
Returns this connection's protocol version or
null if unknown. |
SocketAddress |
getRemoteAddress()
Returns this connection's remote address or
null if it is not connected yet or
unconnected. |
Timeout |
getSocketTimeout()
Returns the socket timeout value.
|
SSLSession |
getSSLSession()
Returns this connection's SSL session or
null if TLS has not been activated. |
boolean |
isOpen()
Checks if this connection is open.
|
void |
onConnect() |
void |
onDisconnect() |
void |
onException(Exception cause) |
void |
onInput(ByteBuffer src) |
void |
onOutput() |
void |
onTimeout(Timeout timeout) |
void |
setSocketTimeout(Timeout timeout)
Sets the socket timeout value.
|
String |
toString() |
public ServerH2StreamMultiplexer(ProtocolIOSession ioSession, FrameFactory frameFactory, HttpProcessor httpProcessor, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, CharCodingConfig charCodingConfig, H2Config h2Config, H2StreamListener streamListener)
public ServerH2StreamMultiplexer(ProtocolIOSession ioSession, HttpProcessor httpProcessor, HandlerFactory<AsyncServerExchangeHandler> exchangeHandlerFactory, CharCodingConfig charCodingConfig, H2Config h2Config)
public String getId()
getId in interface Identifiablepublic final void onConnect()
throws HttpException,
IOException
HttpExceptionIOExceptionpublic final void onInput(ByteBuffer src) throws HttpException, IOException
HttpExceptionIOExceptionpublic final void onOutput()
throws HttpException,
IOException
HttpExceptionIOExceptionpublic final void onTimeout(Timeout timeout) throws HttpException, IOException
HttpExceptionIOExceptionpublic final void onDisconnect()
public final void onException(Exception cause)
public void close()
throws IOException
HttpConnectionshutdown instead.close in interface Closeableclose in interface AutoCloseableclose in interface HttpConnectionIOExceptionpublic void close(CloseMode closeMode)
ModalCloseableclose in interface ModalCloseablecloseMode - How to close the receiver.public boolean isOpen()
HttpConnectionisOpen in interface HttpConnectionpublic void setSocketTimeout(Timeout timeout)
SocketModalCloseablesetSocketTimeout in interface SocketModalCloseabletimeout - timeout valuepublic SSLSession getSSLSession()
HttpConnectionnull if TLS has not been activated.getSSLSession in interface HttpConnectionnull if TLS has not been activated.public EndpointDetails getEndpointDetails()
HttpConnectiongetEndpointDetails in interface HttpConnectionpublic Timeout getSocketTimeout()
SocketModalCloseablegetSocketTimeout in interface SocketModalCloseablepublic ProtocolVersion getProtocolVersion()
HttpConnectionnull if unknown.getProtocolVersion in interface HttpConnectionnull if unknown.public SocketAddress getRemoteAddress()
HttpConnectionnull if it is not connected yet or
unconnected.getRemoteAddress in interface HttpConnectionnull if it is not connected yet or
unconnected.public SocketAddress getLocalAddress()
HttpConnectionnull if it is not bound yet.getLocalAddress in interface HttpConnectionnull if it is not bound yet.Copyright © 2005–2022 The Apache Software Foundation. All rights reserved.