All Implemented Interfaces:: ai.platon.pulsar.experimental.transport.ChannelHandler


public final class PersistHandler
extends ChannelHandlerAdapter

Fields
Modifier and Type	Field	Description
`private final String`	`url`
`private final PulsarSession`	`session`

Constructors
Constructor	Description
`PersistHandler(String url, PulsarSession session)`

Modifier and Type	Method	Description
`final String`	`getUrl()`
`final PulsarSession`	`getSession()`
`Unit`	`channelRead(ChannelHandlerContext context, Object msg)`
`Unit`	`channelWrite(ChannelHandlerContext context, Object msg)`

Methods inherited from class ai.platon.pulsar.experimental.transport.PersistHandler
handlerAdded, handlerRemoved
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

PersistHandler(String url, PulsarSession session)

 Unit channelRead(ChannelHandlerContext context, Object msg)

 Unit channelWrite(ChannelHandlerContext context, Object msg)

Class PersistHandler