-
- All Implemented Interfaces:
-
ai.platon.pulsar.common.config.KConfigurable,ai.platon.pulsar.experimental.transport.ChannelHandlerContext
public abstract class AbstractChannelHandlerContext implements ChannelHandlerContext
-
-
Field Summary
Fields Modifier and Type Field Description private ImmutableConfigconfprivate ChannelHandlerContextprevprivate ChannelHandlerContextnextprivate final DefaultChannelPipelinepipelineprivate final ExecutorServiceexecutorprivate final Stringnameprivate final ChannelHandlerhandlerprivate final Channelchannel
-
Constructor Summary
Constructors Constructor Description AbstractChannelHandlerContext(DefaultChannelPipeline pipeline, ExecutorService executor, String name, KClass<out ChannelHandler> handlerClass)AbstractChannelHandlerContext(DefaultChannelPipeline pipeline, ExecutorService executor, String name, ChannelHandler handler)
-
Method Summary
Modifier and Type Method Description ImmutableConfiggetConf()UnitsetConf(ImmutableConfig conf)ChannelHandlerContextgetPrev()UnitsetPrev(ChannelHandlerContext prev)ChannelHandlerContextgetNext()UnitsetNext(ChannelHandlerContext next)DefaultChannelPipelinegetPipeline()ExecutorServicegetExecutor()StringgetName()ChannelHandlergetHandler()abstract ChannelgetChannel()ChannelHandlerContextread()ChannelHandlerContextflush()ChannelHandlerContextfireChannelRead(Object msg)ChannelHandlerContextfireChannelReadComplete(Object msg)ChannelHandlerContextfireUserEventTriggered(Object msg)ChannelHandlerContextfireExceptionCaught(Object msg)-
-
Constructor Detail
-
AbstractChannelHandlerContext
AbstractChannelHandlerContext(DefaultChannelPipeline pipeline, ExecutorService executor, String name, KClass<out ChannelHandler> handlerClass)
-
AbstractChannelHandlerContext
AbstractChannelHandlerContext(DefaultChannelPipeline pipeline, ExecutorService executor, String name, ChannelHandler handler)
-
-
Method Detail
-
getConf
ImmutableConfig getConf()
-
getPrev
ChannelHandlerContext getPrev()
-
setPrev
Unit setPrev(ChannelHandlerContext prev)
-
getNext
ChannelHandlerContext getNext()
-
setNext
Unit setNext(ChannelHandlerContext next)
-
getPipeline
DefaultChannelPipeline getPipeline()
-
getExecutor
ExecutorService getExecutor()
-
getHandler
ChannelHandler getHandler()
-
getChannel
abstract Channel getChannel()
-
read
ChannelHandlerContext read()
-
flush
ChannelHandlerContext flush()
-
fireChannelRead
ChannelHandlerContext fireChannelRead(Object msg)
-
fireChannelReadComplete
ChannelHandlerContext fireChannelReadComplete(Object msg)
-
fireUserEventTriggered
ChannelHandlerContext fireUserEventTriggered(Object msg)
-
fireExceptionCaught
ChannelHandlerContext fireExceptionCaught(Object msg)
-
-
-
-