refactoring

redisson/src/main/java/org/redisson/RedissonExecutorService.java

@@ -660,7 +660,7 @@ public class RedissonExecutorService implements RScheduledExecutorService {
             }
         };
         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 class RedissonExecutorService implements RScheduledExecutorService {
         }
         
         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);
         }
 

redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java

@@ -365,8 +365,8 @@ abstract class ConnectionPool<T extends RedisConnection> {
                         if (entry.getConfig().getPassword() != null) {
                             RFuture<Void> temp = c.async(RedisCommands.AUTH, config.getPassword());
 
-                            FutureListener<Void> listener = new FutureListener<Void> () {
-                                @Override public void operationComplete (Future < Void > future)throws Exception {
+                            FutureListener<Void> listener = new FutureListener<Void>() {
+                                @Override public void operationComplete(Future<Void> future)throws Exception {
                                     ping(c, pingListener);
                                 }
                             };