https://github.com/fengjiachun/Jupiter/issues/62

fengjiachun · Jun 7, 2018 · c932fd2 · c932fd2
1 parent f486565
commit c932fd2
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/jupiter-rpc/src/main/java/org/jupiter/rpc/consumer/future/DefaultInvokeFuture.java b/jupiter-rpc/src/main/java/org/jupiter/rpc/consumer/future/DefaultInvokeFuture.java
@@ -67,7 +67,7 @@ public class DefaultInvokeFuture<V> extends AbstractListenableFuture<V> implemen
     private static final ConcurrentMap<String, DefaultInvokeFuture<?>> broadcastFutures =
             Maps.newConcurrentMap(FUTURES_CONTAINER_INITIAL_CAPACITY);
 
-    private static final HashedWheelTimer futuresTimeoutScanner =
+    private static final HashedWheelTimer timeoutScanner =
             new HashedWheelTimer(
                     new NamedThreadFactory("futures.timeout.scanner", true),
                     TIMEOUT_SCANNER_INTERVAL_MILLIS, TimeUnit.MILLISECONDS
@@ -114,7 +114,7 @@ private DefaultInvokeFuture(
                 throw new IllegalArgumentException("Unsupported " + dispatchType);
         }
 
-        futuresTimeoutScanner.newTimeout(timeoutTask, timeout, TimeUnit.NANOSECONDS);
+        timeoutScanner.newTimeout(timeoutTask, timeout, TimeUnit.NANOSECONDS);
     }
 
     public JChannel channel() {
@@ -264,7 +264,7 @@ private static String subInvokeId(String channelId, long invokeId) {
         return channelId + invokeId;
     }
 
-    final static class TimeoutTask implements TimerTask {
+    static final class TimeoutTask implements TimerTask {
 
         private final String channelId;
         private final long invokeId;