Polishing

README.md

@@ -8,7 +8,7 @@ Lettuce is a scalable thread-safe Redis client providing synchronous,
 asynchronous and reactive APIs. Multiple threads may share one connection if they avoid blocking and transactional
 operations such as `BLPOP` and  `MULTI`/`EXEC`.
 Multiple connections are efficiently managed by the excellent netty NIO
-framework. Support for advanced Redis features such as Sentinel, Cluster and Redis data models
+framework. Support for advanced Redis features such as Sentinel, Cluster, and Redis data models
 is included.
 
 This version of lettuce has been tested against Redis and 3.0.

src/main/java/com/lambdaworks/redis/RedisConnectionPool.java

@@ -176,7 +176,8 @@ void addListener(CloseEvents.CloseListener listener) {
      * @since 3.0
      */
     static class PooledConnectionInvocationHandler<T> extends AbstractInvocationHandler {
-        public static final Set<String> DISABLED_METHODS = ImmutableSet.of("auth", "select", "quit", "getStatefulConnection", "setAutoFlushCommands");
+        public static final Set<String> DISABLED_METHODS = ImmutableSet.of("auth", "select", "quit", "getStatefulConnection",
+                "setAutoFlushCommands");
 
         private T connection;
         private final RedisConnectionPool<T> pool;

src/main/java/com/lambdaworks/redis/protocol/CommandHandler.java

@@ -507,7 +507,7 @@ public void setRedisChannelHandler(RedisChannelHandler<K, V> redisChannelHandler
     public void setAutoFlushCommands(boolean autoFlush) {
         synchronized (stateLock) {
             this.autoFlushCommands = autoFlush;
- }
+        }
     }
 
     private String logPrefix() {

src/test/java/com/lambdaworks/redis/cluster/commands/GeoClusterCommandTest.java

@@ -2,15 +2,13 @@
 
 import static com.lambdaworks.redis.cluster.ClusterTestUtil.flushClusterDb;
 
-import java.util.concurrent.TimeUnit;
-
 import com.lambdaworks.redis.FastShutdown;
 import com.lambdaworks.redis.cluster.api.StatefulRedisClusterConnection;
 import org.junit.AfterClass;
 import org.junit.Before;
 import org.junit.BeforeClass;
 
-import com.lambdaworks.redis.GeoCommandTest;
+import com.lambdaworks.redis.commands.GeoCommandTest;
 import com.lambdaworks.redis.RedisURI;
 import com.lambdaworks.redis.TestSettings;
 import com.lambdaworks.redis.api.sync.RedisCommands;

src/test/java/com/lambdaworks/redis/GeoCommandTest.java → src/test/java/com/lambdaworks/redis/commands/GeoCommandTest.java

@@ -1,4 +1,4 @@
-package com.lambdaworks.redis;
+package com.lambdaworks.redis.commands;
 
 import static org.assertj.core.api.Assertions.*;
 import static org.assertj.core.api.Assertions.assertThat;
@@ -7,6 +7,7 @@
 import java.util.List;
 import java.util.Set;
 
+import com.lambdaworks.redis.*;
 import org.junit.Rule;
 import org.junit.Test;
 import org.junit.rules.ExpectedException;

src/test/java/com/lambdaworks/redis/commands/rx/GeoRxCommandTest.java

@@ -1,8 +1,7 @@
 package com.lambdaworks.redis.commands.rx;
 
-import com.lambdaworks.redis.GeoCommandTest;
+import com.lambdaworks.redis.commands.GeoCommandTest;
 import com.lambdaworks.redis.api.sync.RedisCommands;
-import com.lambdaworks.redis.commands.ScriptingCommandTest;
 
 public class GeoRxCommandTest extends GeoCommandTest {