Package software.amazon.awssdk.http.nio.netty.internal

Class InUseTrackingChannelPoolListener

java.lang.Object

software.amazon.awssdk.http.nio.netty.internal.InUseTrackingChannelPoolListener

All Implemented Interfaces:

ListenerInvokingChannelPool.ChannelPoolListener

@SdkInternalApi
public final class InUseTrackingChannelPoolListener
extends Object
implements ListenerInvokingChannelPool.ChannelPoolListener

Marks Channels as in-use when they are leased from the pool. An in-use channel is not eligible to be closed by IdleConnectionReaperHandler or OldConnectionReaperHandler.

Method Summary

Modifier and Type	Method	Description
void	channelAcquired(io.netty.channel.Channel channel)	Called after a Channel was acquired by calling ChannelPool.acquire() or ChannelPool.acquire(Promise).
void	channelReleased(io.netty.channel.Channel channel)	Called before a Channel is released by calling ChannelPool.release(Channel) or ChannelPool.release(Channel, Promise).
static InUseTrackingChannelPoolListener	create()

Methods inherited from class java.lang.Object

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

Method Details

create

public static InUseTrackingChannelPoolListener create()

channelAcquired

public void channelAcquired(io.netty.channel.Channel channel)

Description copied from interface: ListenerInvokingChannelPool.ChannelPoolListener

Called after a Channel was acquired by calling ChannelPool.acquire() or ChannelPool.acquire(Promise).

This method will be called by the EventLoop of the Channel.

Specified by:

channelAcquired in interface ListenerInvokingChannelPool.ChannelPoolListener

channelReleased

public void channelReleased(io.netty.channel.Channel channel)

Description copied from interface: ListenerInvokingChannelPool.ChannelPoolListener

Called before a Channel is released by calling ChannelPool.release(Channel) or ChannelPool.release(Channel, Promise).

This method will be called by the EventLoop of the Channel.

Specified by:

channelReleased in interface ListenerInvokingChannelPool.ChannelPoolListener