undertow-core-2.0.13.Final.jar
登录
|
io.undertow:undertow-core:2.0.13.Final
io
undertow
io
UndertowOptions.java
security
protocols
conduits
predicate
connector
util
Version.java
Undertow.java
UndertowLogger.java
version.properties
channels
UndertowLogger_$logger.java
server
XnioByteBufferPool.java
OpenListener.java
Connectors.java
protocol
ParseTimeoutUpdater.java
http
proxy
ProxyProtocolOpenListener.java
ProxyProtocolReadListener.java
framed
ajp
http2
session
SSLSessionInfo.java
handlers
RequestTooBigException.java
DefaultByteBufferPool.java
ServerConnection.java
ConduitWrapper.java
HandlerWrapper.java
BlockingHttpExchange.java
HttpServerExchange.java
DelegateOpenListener.java
AggregateConnectorStatistics.java
ConnectorStatistics.java
AbstractServerConnection.java
JvmRouteHandler.java
TruncatedResponseException.java
ResponseCommitListener.java
RoutingHandler.java
ListenerRegistry.java
SecureCookieCommitListener.java
DefaultResponseListener.java
HttpUpgradeListener.java
ExchangeCompletionListener.java
ConnectionSSLSessionInfo.java
RenegotiationRequiredException.java
XnioBufferPoolAdaptor.java
BasicSSLSessionInfo.java
DirectByteBufferDeallocator.java
HttpHandler.java
ConnectorStatisticsImpl.java
attribute
UndertowMessages_$bundle.java
Handlers.java
client
websockets
UndertowMessages.java
META-INF
ProxyProtocolOpenListener.java
清空
类结构
package io.undertow.server.protocol.proxy; import io.undertow.connector.
ByteBufferPool
; import io.undertow.protocols.ssl.
UndertowXnioSsl
; import io.undertow.server.
OpenListener
; import org.xnio.
ChannelListener
; import org.xnio.
OptionMap
; import org.xnio.
StreamConnection
; /** * Open listener for proxied connections * * @author Stuart Douglas */ public class
ProxyProtocolOpenListener
implements
ChannelListener
<
StreamConnection
> { private final
OpenListener
openListener
; private final
UndertowXnioSsl
ssl
; private final
ByteBufferPool
bufferPool
; private final
OptionMap
sslOptionMap
; public
ProxyProtocolOpenListener
(
OpenListener
openListener
,
UndertowXnioSsl
ssl
,
ByteBufferPool
bufferPool
,
OptionMap
sslOptionMap
) { this.
openListener
=
openListener
; this.
ssl
=
ssl
; this.
bufferPool
=
bufferPool
; this.
sslOptionMap
=
sslOptionMap
; } @
Override
public void
handleEvent
(
StreamConnection
streamConnection
) {
streamConnection
.
getSourceChannel
().
setReadListener
(new
ProxyProtocolReadListener
(
streamConnection
,
openListener
,
ssl
,
bufferPool
,
sslOptionMap
));
streamConnection
.
getSourceChannel
().
wakeupReads
(); } }
查找资源
Jre/Lib
输入类名或文件名
类结构窗口