fix comment

leonchen83 · Aug 23, 2016 · 62732ad · 62732ad
1 parent 0438788
commit 62732ad
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java b/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java
@@ -198,7 +198,7 @@ private void auth(String password) throws IOException {
     }
 
     private void sendSlavePort() throws IOException {
-        //REPLCONF listening-prot 6380
+        //REPLCONF listening-prot ${port}
         logger.info("REPLCONF listening-port " + socket.getLocalPort());
         send("REPLCONF".getBytes(), "listening-port".getBytes(), String.valueOf(socket.getLocalPort()).getBytes());
         final String reply = (String) reply();
@@ -208,7 +208,7 @@ private void sendSlavePort() throws IOException {
     }
 
     private void sendSlaveIp() throws IOException {
-        //REPLCONF capa eof
+        //REPLCONF ip-address ${address}
         logger.info("REPLCONF ip-address " + socket.getLocalAddress().getHostAddress());
         send("REPLCONF".getBytes(), "ip-address".getBytes(), socket.getLocalAddress().getHostAddress().getBytes());
         final String reply = (String) reply();