diff options
Diffstat (limited to 'documentapi')
-rwxr-xr-x | documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java index 7e9faa9a8ea..306103f2912 100755 --- a/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java +++ b/documentapi/src/main/java/com/yahoo/documentapi/messagebus/MessageBusVisitorSession.java @@ -949,15 +949,15 @@ public class MessageBusVisitorSession implements VisitorSession { return TimeUnit.NANOSECONDS.toMillis(clock.monotonicNanoTime() - startTimeNanos); } - private static boolean isInfiniteTimeout(long timeoutMs) { - return timeoutMs < 0; + private static boolean isInfiniteTimeout(long timeoutMillis) { + return timeoutMillis < 0; } private long computeBoundedMessageTimeoutMillis(long elapsedMs) { - final long messageTimeoutMs = messageTimeoutMillis(); + final long messageTimeoutMillis = messageTimeoutMillis(); return !isInfiniteTimeout(sessionTimeoutMillis()) - ? Math.min(sessionTimeoutMillis() - elapsedMs, messageTimeoutMs) - : messageTimeoutMs; + ? Math.min(sessionTimeoutMillis() - elapsedMs, messageTimeoutMillis) + : messageTimeoutMillis; } /** |