-
- All Implemented Interfaces:
-
ai.platon.pulsar.experimental.transport.ChannelHandler
public final class ParseHandler extends ChannelHandlerAdapter
-
-
Field Summary
Fields Modifier and Type Field Description private final Stringurlprivate final PulsarSessionsession
-
Constructor Summary
Constructors Constructor Description ParseHandler(String url, PulsarSession session)
-
Method Summary
Modifier and Type Method Description final StringgetUrl()final PulsarSessiongetSession()UnitchannelRead(ChannelHandlerContext context, Object msg)UnitchannelWrite(ChannelHandlerContext context, Object msg)-
-
Constructor Detail
-
ParseHandler
ParseHandler(String url, PulsarSession session)
-
-
Method Detail
-
getSession
final PulsarSession getSession()
-
channelRead
Unit channelRead(ChannelHandlerContext context, Object msg)
-
channelWrite
Unit channelWrite(ChannelHandlerContext context, Object msg)
-
-
-
-