Package org.ldaptive.transport.netty

Class NettyConnection.AddRemoveHandler

java.lang.Object

org.ldaptive.transport.netty.NettyConnection.AddRemoveHandler

All Implemented Interfaces:

io.netty.channel.ChannelHandler

Enclosing class:

NettyConnection

private static final class NettyConnection.AddRemoveHandler
extends Object
implements io.netty.channel.ChannelHandler

Invokes a latch when this handler is added or removed from a pipeline.

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
private final CountDownLatch	handlerAddedLatch	Latch to count down when this handler is added.
private final CountDownLatch	handlerRemovedLatch	Latch to count down when this handler is removed.

Constructor Summary

Constructors

Constructor	Description
AddRemoveHandler(CountDownLatch addedLatch, CountDownLatch removedLatch)	Creates a new add remove handler.

Method Summary

Modifier and Type	Method	Description
void	exceptionCaught(io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
void	handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
void	handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)

Methods inherited from class java.lang.Object

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

Field Details

handlerAddedLatch

private final CountDownLatch handlerAddedLatch

Latch to count down when this handler is added.

handlerRemovedLatch

private final CountDownLatch handlerRemovedLatch

Latch to count down when this handler is removed.

Constructor Details

AddRemoveHandler

AddRemoveHandler(CountDownLatch addedLatch,
 CountDownLatch removedLatch)

Creates a new add remove handler.

Parameters:

addedLatch - to invoke handlerAdded(ChannelHandlerContext)

removedLatch - to invoke handlerRemoved(ChannelHandlerContext)

Method Details

handlerAdded

public void handlerAdded(io.netty.channel.ChannelHandlerContext ctx)
                  throws Exception

Specified by:

handlerAdded in interface io.netty.channel.ChannelHandler

Throws:

Exception

handlerRemoved

public void handlerRemoved(io.netty.channel.ChannelHandlerContext ctx)
                    throws Exception

Specified by:

handlerRemoved in interface io.netty.channel.ChannelHandler

Throws:

Exception

exceptionCaught

public void exceptionCaught(io.netty.channel.ChannelHandlerContext ctx,
 Throwable cause)
                     throws Exception

Specified by:

exceptionCaught in interface io.netty.channel.ChannelHandler

Throws:

Exception