refactoring

redisson · Aug 24, 2016 · c9294e1 · c9294e1
1 parent d00a1a7
commit c9294e1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/redisson/src/main/java/org/redisson/RedissonExecutorService.java b/redisson/src/main/java/org/redisson/RedissonExecutorService.java
@@ -660,7 +660,7 @@ public void operationComplete(io.netty.util.concurrent.Future<T> future) throws
             }
         };
         for (Future<T> future : futures) {
-            io.netty.util.concurrent.Future<T> f = (io.netty.util.concurrent.Future<T>) future;
+            RFuture<T> f = (RFuture<T>) future;
             f.addListener(listener);
         }
 
@@ -671,7 +671,7 @@ public void operationComplete(io.netty.util.concurrent.Future<T> future) throws
         }
 
         for (Future<T> future : futures) {
-            io.netty.util.concurrent.Future<T> f = (io.netty.util.concurrent.Future<T>) future;
+            RFuture<T> f = (RFuture<T>) future;
             f.removeListener(listener);
         }
 

diff --git a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java
@@ -365,8 +365,8 @@ public void operationComplete(Future<Void> future)
                         if (entry.getConfig().getPassword() != null) {
                             RFuture<Void> temp = c.async(RedisCommands.AUTH, config.getPassword());
 
-                            FutureListener<Void> listener = new FutureListener<Void> () {
+                            FutureListener<Void> listener = new FutureListener<Void>() {
-                                @Override public void operationComplete (Future < Void > future)throws Exception {
+                                @Override public void operationComplete(Future<Void> future)throws Exception {
                                     ping(c, pingListener);
                                 }
                             };