-
- All Implemented Interfaces:
-
ai.platon.pulsar.experimental.transport.ChannelHandler
public final class FetchHandler extends ChannelHandlerAdapter
-
-
Field Summary
Fields Modifier and Type Field Description private final Stringurlprivate final PulsarSessionsession
-
Constructor Summary
Constructors Constructor Description FetchHandler(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
-
FetchHandler
FetchHandler(String url, PulsarSession session)
-
-
Method Detail
-
getSession
final PulsarSession getSession()
-
channelRead
Unit channelRead(ChannelHandlerContext context, Object msg)
-
channelWrite
Unit channelWrite(ChannelHandlerContext context, Object msg)
-
-
-
-