RObject.copy method added

redisson/src/main/java/org/redisson/RedissonObject.java

@@ -103,6 +103,16 @@ public abstract class RedissonObject implements RObject {
         return commandExecutor.writeAsync(getName(), RedisCommands.MIGRATE, host, port, getName(), database, timeout);
     }
     
+    @Override
+    public void copy(String host, int port, int database, long timeout) {
+        get(copyAsync(host, port, database, timeout));
+    }
+
+    @Override
+    public RFuture<Void> copyAsync(String host, int port, int database, long timeout) {
+        return commandExecutor.writeAsync(getName(), RedisCommands.MIGRATE, host, port, getName(), database, timeout, "COPY");
+    }
+    
     @Override
     public boolean move(int database) {
         return get(moveAsync(database));

redisson/src/main/java/org/redisson/api/RObject.java

@@ -33,7 +33,7 @@ public interface RObject extends RObjectAsync {
     boolean touch();
     
     /**
-     * Transfer an object from source Redis instance to destination Redis instance
+     * Copy object from source Redis instance to destination Redis instance
      *
      * @param host - destination host
      * @param port - destination port
@@ -42,6 +42,16 @@ public interface RObject extends RObjectAsync {
      */
     void migrate(String host, int port, int database, long timeout);
 
+    /**
+     * Copy object from source Redis instance to destination Redis instance
+     *
+     * @param host - destination host
+     * @param port - destination port
+     * @param database - destination database
+     * @param timeout - maximum idle time in any moment of the communication with the destination instance in milliseconds
+     */
+    void copy(String host, int port, int database, long timeout);
+    
     /**
      * Move object to another database
      *

redisson/src/main/java/org/redisson/api/RObjectAsync.java

@@ -31,7 +31,7 @@ public interface RObjectAsync {
     RFuture<Boolean> touchAsync();
     
     /**
-     * Transfer an object from source Redis instance to destination Redis instance
+     * Transfer object from source Redis instance to destination Redis instance
      * in async mode
      *
      * @param host - destination host
@@ -42,6 +42,18 @@ public interface RObjectAsync {
      */
     RFuture<Void> migrateAsync(String host, int port, int database, long timeout);
 
+    /**
+     * Copy object from source Redis instance to destination Redis instance
+     * in async mode
+     *
+     * @param host - destination host
+     * @param port - destination port
+     * @param database - destination database
+     * @param timeout - maximum idle time in any moment of the communication with the destination instance in milliseconds
+     * @return void
+     */
+    RFuture<Void> copyAsync(String host, int port, int database, long timeout);
+    
     /**
      * Move object to another database in async mode
      *

redisson/src/test/java/org/redisson/RedissonBucketTest.java

@@ -142,6 +142,29 @@ public class RedissonBucketTest extends BaseTest {
         runner.stop();
     }
 
+    @Test
+    public void testCopy() throws FailedToStartRedisException, IOException, InterruptedException {
+        RedisProcess runner = new RedisRunner()
+                .appendonly(true)
+                .randomDir()
+                .randomPort()
+                .run();
+        
+        RBucket<String> bucket = redisson.getBucket("test");
+        bucket.set("someValue");
+        
+        bucket.copy(runner.getRedisServerBindAddress(), runner.getRedisServerPort(), 0, 5000);
+        
+        Config config = new Config();
+        config.useSingleServer().setAddress(runner.getRedisServerAddressAndPort());
+        RedissonClient r = Redisson.create(config);
+        
+        RBucket<String> bucket2 = r.getBucket("test");
+        assertThat(bucket2.get()).isEqualTo("someValue");
+        assertThat(bucket.get()).isEqualTo("someValue");
+        
+        runner.stop();
+    }
 
     @Test
     public void testRename() {