Package org.mockserver.netty.connection

Class HttpExchangeTracker

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelDuplexHandler

org.mockserver.netty.connection.HttpExchangeTracker

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler, io.netty.channel.ChannelOutboundHandler

@Sharable
public final class HttpExchangeTracker
extends io.netty.channel.ChannelDuplexHandler

Counts HTTP/1.1 exchanges in progress on a connection for InboundConnectionIdleHandler: an exchange starts when a request head is decoded and ends when the last part of its response has been written to the socket, so a delayed, paused or streaming response keeps the connection busy.

Must sit after HttpServerCodec, ahead of every handler that answers, so it sees every decoded request and every encoded response whichever handler writes it. The client's leg of an HTTP/1.1 CONNECT/SOCKS tunnel has one after the tunnel's own codec, where an exchange spans the upload of its request and the relay of its response. A 101 Switching Protocols response makes the connection long-lived (it is a WebSocket from then on); other 1xx responses, such as 100 Continue, precede the real response and do not end the exchange. An exchange that ends without a LastHttpContent passing through (a raw-bytes HttpError, an abandoned exchange, a final 1xx) is ended by HttpExchangeEndedEvent; without it the connection would count as busy for the rest of its life and never be closed as idle.

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field	Description
static final HttpExchangeTracker	INSTANCE

Method Summary

Modifier and Type	Method	Description
void	channelRead(io.netty.channel.ChannelHandlerContext ctx, Object msg)
void	userEventTriggered(io.netty.channel.ChannelHandlerContext ctx, Object evt)
void	write(io.netty.channel.ChannelHandlerContext ctx, Object msg, io.netty.channel.ChannelPromise promise)

Methods inherited from class io.netty.channel.ChannelDuplexHandler

bind, close, connect, deregister, disconnect, flush, read

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Field Details

INSTANCE

public static final HttpExchangeTracker INSTANCE

Method Details

channelRead

public void channelRead(io.netty.channel.ChannelHandlerContext ctx,
 Object msg)

Specified by:

channelRead in interface io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class io.netty.channel.ChannelInboundHandlerAdapter

userEventTriggered

public void userEventTriggered(io.netty.channel.ChannelHandlerContext ctx,
 Object evt)

Specified by:

userEventTriggered in interface io.netty.channel.ChannelInboundHandler

Overrides:

userEventTriggered in class io.netty.channel.ChannelInboundHandlerAdapter

write

public void write(io.netty.channel.ChannelHandlerContext ctx,
 Object msg,
 io.netty.channel.ChannelPromise promise)

Specified by:

write in interface io.netty.channel.ChannelOutboundHandler

Overrides:

write in class io.netty.channel.ChannelDuplexHandler