diff --git a/artio-core/src/main/java/uk/co/real_logic/artio/engine/framer/ResetSequenceNumberCommand.java b/artio-core/src/main/java/uk/co/real_logic/artio/engine/framer/ResetSequenceNumberCommand.java index fc944db02e..21b523fe01 100644 --- a/artio-core/src/main/java/uk/co/real_logic/artio/engine/framer/ResetSequenceNumberCommand.java +++ b/artio-core/src/main/java/uk/co/real_logic/artio/engine/framer/ResetSequenceNumberCommand.java @@ -153,7 +153,6 @@ public void execute(final Framer framer) // Only to be called on the Framer thread. boolean poll() { - if (clock.nanoTime() - resetTimeInNs >= timeoutInNs) { return onTimeout(); @@ -300,7 +299,7 @@ private boolean onTimeout() if (isAdminReset) { if (adminReplyPublication.saveGenericAdminReply(adminCorrelationId, GatewayError.EXCEPTION, - sessionId + " sequence numbers not reset in " + timeoutInNs + "ns") > 0) + sessionId + " sequence numbers not reset in " + timeoutInNs + "ns") > 0) { state = TIMED_OUT; return true;