Package org.apache.bookkeeper.proto
Class ReadLacProcessorV3
- java.lang.Object
-
- org.apache.bookkeeper.util.SafeRunnable
-
- org.apache.bookkeeper.proto.PacketProcessorBaseV3
-
- org.apache.bookkeeper.proto.ReadLacProcessorV3
-
- All Implemented Interfaces:
java.lang.Runnable
,SafeRunnable
class ReadLacProcessorV3 extends PacketProcessorBaseV3 implements java.lang.Runnable
A read processor for v3 last add confirmed messages.
-
-
Field Summary
-
Fields inherited from class org.apache.bookkeeper.proto.PacketProcessorBaseV3
channel, enqueueNanos, request, requestProcessor
-
Fields inherited from interface org.apache.bookkeeper.common.util.SafeRunnable
LOGGER
-
-
Constructor Summary
Constructors Constructor Description ReadLacProcessorV3(org.apache.bookkeeper.proto.BookkeeperProtocol.Request request, io.netty.channel.Channel channel, BookieRequestProcessor requestProcessor)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
safeRun()
-
Methods inherited from class org.apache.bookkeeper.proto.PacketProcessorBaseV3
getHeader, isVersionCompatible, sendResponse, toString
-
Methods inherited from class org.apache.bookkeeper.util.SafeRunnable
safeRun, safeRun
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.bookkeeper.common.util.SafeRunnable
run
-
-
-
-
Constructor Detail
-
ReadLacProcessorV3
public ReadLacProcessorV3(org.apache.bookkeeper.proto.BookkeeperProtocol.Request request, io.netty.channel.Channel channel, BookieRequestProcessor requestProcessor)
-
-
Method Detail
-
safeRun
public void safeRun()
- Specified by:
safeRun
in interfaceSafeRunnable
-
-