org.apache.flink.statefun.flink.core.nettyclient

Class NettyRequestReplyHandler

java.lang.Object

org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerAdapter

org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter

org.apache.flink.shaded.netty4.io.netty.channel.ChannelDuplexHandler

org.apache.flink.statefun.flink.core.nettyclient.NettyRequestReplyHandler

All Implemented Interfaces:

org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler, org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler, org.apache.flink.shaded.netty4.io.netty.channel.ChannelOutboundHandler

public final class NettyRequestReplyHandler
extends org.apache.flink.shaded.netty4.io.netty.channel.ChannelDuplexHandler

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler

org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler.Sharable

Constructor Summary

Constructors

Constructor and Description
NettyRequestReplyHandler()

Method Summary

Modifier and Type	Method and Description
void	channelInactive(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx)
void	channelRead(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx, java.lang.Object message)
void	channelUnregistered(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx)
void	exceptionCaught(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx, java.lang.Throwable cause)
void	onReleaseToPool()
void	write(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg, org.apache.flink.shaded.netty4.io.netty.channel.ChannelPromise promise)

Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.ChannelDuplexHandler

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

Methods inherited from class org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelReadComplete, channelRegistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class org.apache.flink.shaded.netty4.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 org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler

handlerAdded, handlerRemoved

Constructor Detail

NettyRequestReplyHandler

public NettyRequestReplyHandler()

Method Detail

write

public void write(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
                  java.lang.Object msg,
                  org.apache.flink.shaded.netty4.io.netty.channel.ChannelPromise promise)
           throws java.lang.Exception

Specified by:

write in interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelOutboundHandler

Overrides:

write in class org.apache.flink.shaded.netty4.io.netty.channel.ChannelDuplexHandler

Throws:

java.lang.Exception

channelRead

public void channelRead(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
                        java.lang.Object message)

Specified by:

channelRead in interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler

Overrides:

channelRead in class org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter

exceptionCaught

public void exceptionCaught(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx,
                            java.lang.Throwable cause)

Specified by:

exceptionCaught in interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandler

Specified by:

exceptionCaught in interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler

Overrides:

exceptionCaught in class org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter

onReleaseToPool

public void onReleaseToPool()

channelInactive

public void channelInactive(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx)
                     throws java.lang.Exception

Specified by:

channelInactive in interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler

Overrides:

channelInactive in class org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter

Throws:

java.lang.Exception

channelUnregistered

public void channelUnregistered(org.apache.flink.shaded.netty4.io.netty.channel.ChannelHandlerContext ctx)
                         throws java.lang.Exception

Specified by:

channelUnregistered in interface org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandler

Overrides:

channelUnregistered in class org.apache.flink.shaded.netty4.io.netty.channel.ChannelInboundHandlerAdapter

Throws:

java.lang.Exception