fix port sanity check

leonchen83 · Jul 12, 2017 · 76ebc32 · 76ebc32
1 parent 2da7332
commit 76ebc32
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java b/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java
@@ -54,7 +54,7 @@ public class RedisSocketReplicator extends AbstractReplicator {
 
     public RedisSocketReplicator(String host, int port, Configuration configuration) {
         Objects.requireNonNull(host);
-        if (port <= 0) throw new IllegalArgumentException("illegal argument port: " + port);
+        if (port <= 0 || port > 65535) throw new IllegalArgumentException("illegal argument port: " + port);
         Objects.requireNonNull(configuration);
         this.host = host;
         this.port = port;