Package org.mockserver.proxy.relay
Class RelayConnectHandler<T>
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelInboundHandlerAdapter
-
- io.netty.channel.SimpleChannelInboundHandler<T>
-
- org.mockserver.proxy.relay.RelayConnectHandler<T>
-
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
- Direct Known Subclasses:
HttpConnectHandler
,SocksConnectHandler
@Sharable public abstract class RelayConnectHandler<T> extends io.netty.channel.SimpleChannelInboundHandler<T>
-
-
Field Summary
Fields Modifier and Type Field Description static io.netty.util.AttributeKey<List<Future<io.netty.channel.Channel>>>
HTTP_CONNECT_SOCKET
-
Constructor Summary
Constructors Constructor Description RelayConnectHandler(LifeCycle server, MockServerLogger mockServerLogger, String host, int port)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
channelRead0(io.netty.channel.ChannelHandlerContext serverCtx, T request)
void
exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
protected abstract Object
failureResponse(Object request)
protected abstract void
removeCodecSupport(io.netty.channel.ChannelHandlerContext ctx)
protected void
removeHandler(io.netty.channel.ChannelPipeline pipeline, io.netty.channel.ChannelHandler channelHandler)
protected void
removeHandler(io.netty.channel.ChannelPipeline pipeline, Class<? extends io.netty.channel.ChannelHandler> handlerType)
protected abstract Object
successResponse(Object request)
-
Methods inherited from class io.netty.channel.SimpleChannelInboundHandler
acceptInboundMessage, channelRead
-
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
-
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
-
-
-
-
Constructor Detail
-
RelayConnectHandler
public RelayConnectHandler(LifeCycle server, MockServerLogger mockServerLogger, String host, int port)
-
-
Method Detail
-
channelRead0
public void channelRead0(io.netty.channel.ChannelHandlerContext serverCtx, T request)
- Specified by:
channelRead0
in classio.netty.channel.SimpleChannelInboundHandler<T>
-
exceptionCaught
public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
- Specified by:
exceptionCaught
in interfaceio.netty.channel.ChannelHandler
- Specified by:
exceptionCaught
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
exceptionCaught
in classio.netty.channel.ChannelInboundHandlerAdapter
-
removeCodecSupport
protected abstract void removeCodecSupport(io.netty.channel.ChannelHandlerContext ctx)
-
removeHandler
protected void removeHandler(io.netty.channel.ChannelPipeline pipeline, Class<? extends io.netty.channel.ChannelHandler> handlerType)
-
removeHandler
protected void removeHandler(io.netty.channel.ChannelPipeline pipeline, io.netty.channel.ChannelHandler channelHandler)
-
-