}
@Override
- protected void forwardEntry(final ConnectionEntry entry) {
- successor().enqueueEntry(entry);
+ protected void forwardEntry(final ConnectionEntry entry, final long now) {
+ successor().sendEntry(entry, now);
+ }
+
+ @Override
+ protected void replayEntry(final ConnectionEntry entry, final long now) {
+ // We are executing in the context of the client thread, do not block
+ successor().enqueueEntry(entry, now);
}
}