changelog

Author: chenby

src/main/java/com/moilioncircle/redis/replicator/cmd/impl/MSetExCommand.java

@@ -30,7 +30,7 @@ public class MSetExCommand extends AbstractCommand {
 
     private static final long serialVersionUID = 1L;
 
-    private Map<byte[], byte[]> keyValues;
+    private Map<byte[], byte[]> kv;
     private boolean keepTtl;
     private ExpiredType expiredType;
     private Long expiredValue;
@@ -41,8 +41,8 @@ public class MSetExCommand extends AbstractCommand {
     public MSetExCommand() {
     }
 
-    public MSetExCommand(Map<byte[], byte[]> keyValues, boolean keepTtl, ExpiredType expiredType, Long expiredValue, XATType xatType, Long xatValue, ExistType existType) {
-        this.keyValues = keyValues;
+    public MSetExCommand(Map<byte[], byte[]> kv, boolean keepTtl, ExpiredType expiredType, Long expiredValue, XATType xatType, Long xatValue, ExistType existType) {
+        this.kv = kv;
         this.keepTtl = keepTtl;
         this.expiredType = expiredType;
         this.expiredValue = expiredValue;
@@ -51,12 +51,12 @@ public MSetExCommand(Map<byte[], byte[]> keyValues, boolean keepTtl, ExpiredType
         this.existType = existType;
     }
 
-    public Map<byte[], byte[]> getKeyValues() {
-        return keyValues;
+    public Map<byte[], byte[]> getKv() {
+        return kv;
     }
 
-    public void setKeyValues(Map<byte[], byte[]> keyValues) {
-        this.keyValues = keyValues;
+    public void setKv(Map<byte[], byte[]> kv) {
+        this.kv = kv;
     }
 
     public boolean isKeepTtl() {

src/test/java/com/moilioncircle/redis/replicator/cmd/parser/MSetExParserTest.java

@@ -37,11 +37,11 @@ public void testParse() {
         {
             MSetExParser parser = new MSetExParser();
             MSetExCommand command = parser.parse(toObjectArray("msetex 2 k1 v1 k2 v2 nx ex 100".split(" ")));
-            assertEquals(2, command.getKeyValues().size());
-            assertTrue(command.getKeyValues().containsKey("k1".getBytes()));
-            assertTrue(command.getKeyValues().containsKey("k2".getBytes()));
-            assertEquals("v1", command.getKeyValues().get("k1".getBytes()));
-            assertEquals("v2", command.getKeyValues().get("k2".getBytes()));
+            assertEquals(2, command.getKv().size());
+            assertTrue(command.getKv().containsKey("k1".getBytes()));
+            assertTrue(command.getKv().containsKey("k2".getBytes()));
+            assertEquals("v1", command.getKv().get("k1".getBytes()));
+            assertEquals("v2", command.getKv().get("k2".getBytes()));
             TestCase.assertEquals(ExpiredType.SECOND, command.getExpiredType());
             assertEquals(100L, command.getExpiredValue());
             TestCase.assertEquals(ExistType.NX, command.getExistType());
@@ -50,9 +50,9 @@ public void testParse() {
         {
             MSetExParser parser = new MSetExParser();
             MSetExCommand command = parser.parse(toObjectArray("msetex 1 k1 v1 nx keepttl".split(" ")));
-            assertEquals(1, command.getKeyValues().size());
-            assertTrue(command.getKeyValues().containsKey("k1".getBytes()));
-            assertEquals("v1", command.getKeyValues().get("k1".getBytes()));
+            assertEquals(1, command.getKv().size());
+            assertTrue(command.getKv().containsKey("k1".getBytes()));
+            assertEquals("v1", command.getKv().get("k1".getBytes()));
             TestCase.assertTrue(command.isKeepTtl());
         }
     }