@Override
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);
}
}