command package added

src/main/java/org/redisson/Redisson.java

@@ -25,6 +25,8 @@ import java.util.concurrent.atomic.AtomicLong;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.cluster.ClusterConnectionManager;
+import org.redisson.command.CommandExecutor;
+import org.redisson.command.CommandSyncService;
 import org.redisson.connection.ConnectionManager;
 import org.redisson.connection.ElasticacheConnectionManager;
 import org.redisson.connection.MasterSlaveConnectionManager;

src/main/java/org/redisson/RedissonAtomicLong.java

@@ -19,6 +19,7 @@ import java.util.Collections;
 
 import org.redisson.client.codec.StringCodec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RAtomicLong;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonBatch.java

@@ -18,6 +18,7 @@ package org.redisson;
 import java.util.List;
 
 import org.redisson.client.codec.Codec;
+import org.redisson.command.CommandBatchAsyncService;
 import org.redisson.connection.ConnectionManager;
 import org.redisson.core.RAtomicLongAsync;
 import org.redisson.core.RBatch;

src/main/java/org/redisson/RedissonBitSet.java

@@ -23,6 +23,8 @@ import java.util.List;
 
 import org.redisson.client.codec.ByteArrayCodec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
+import org.redisson.command.CommandBatchAsyncService;
 import org.redisson.core.RBitSet;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonBlockingQueue.java

@@ -26,6 +26,7 @@ import java.util.concurrent.TimeUnit;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommand;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.connection.decoder.ListDrainToDecoder;
 import org.redisson.core.RBlockingQueue;
 

src/main/java/org/redisson/RedissonBucket.java

@@ -19,6 +19,7 @@ import java.util.concurrent.TimeUnit;
 
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RBucket;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonBucketReactive.java

@@ -20,6 +20,7 @@ import java.util.concurrent.TimeUnit;
 import org.reactivestreams.Publisher;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandReactiveExecutor;
 import org.redisson.core.RBucketReactive;
 
 public class RedissonBucketReactive<V> extends RedissonExpirableReactive implements RBucketReactive<V> {

src/main/java/org/redisson/RedissonCountDownLatch.java

@@ -25,6 +25,7 @@ import org.redisson.client.RedisPubSubListener;
 import org.redisson.client.codec.LongCodec;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.client.protocol.pubsub.PubSubType;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RCountDownLatch;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonDeque.java

@@ -24,6 +24,7 @@ import org.redisson.client.protocol.RedisCommand.ValueType;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.client.protocol.convertor.TrueReplayConvertor;
 import org.redisson.client.protocol.convertor.VoidReplayConvertor;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.connection.decoder.ListFirstObjectDecoder;
 import org.redisson.core.RDeque;
 

src/main/java/org/redisson/RedissonExpirable.java

@@ -21,6 +21,7 @@ import java.util.concurrent.TimeUnit;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.codec.StringCodec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RExpirable;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonExpirableReactive.java

@@ -22,6 +22,7 @@ import org.reactivestreams.Publisher;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.codec.StringCodec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandReactiveExecutor;
 import org.redisson.core.RExpirableReactive;
 
 

src/main/java/org/redisson/RedissonHyperLogLog.java

@@ -22,6 +22,7 @@ import java.util.List;
 
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RHyperLogLog;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonHyperLogLogReactive.java

@@ -23,6 +23,7 @@ import java.util.List;
 import org.reactivestreams.Publisher;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandReactiveExecutor;
 import org.redisson.core.RHyperLogLogReactive;
 
 public class RedissonHyperLogLogReactive<V> extends RedissonExpirableReactive implements RHyperLogLogReactive<V> {

src/main/java/org/redisson/RedissonKeys.java

@@ -27,6 +27,7 @@ import org.redisson.client.codec.StringCodec;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.client.protocol.decoder.ListScanResult;
 import org.redisson.cluster.ClusterSlotRange;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RKeys;
 import org.redisson.misc.CompositeIterable;
 

src/main/java/org/redisson/RedissonLexSortedSet.java

@@ -21,6 +21,7 @@ import java.util.List;
 
 import org.redisson.client.codec.StringCodec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RLexSortedSet;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonLexSortedSetReactive.java

@@ -22,6 +22,7 @@ import java.util.List;
 import org.reactivestreams.Publisher;
 import org.redisson.client.codec.StringCodec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandReactiveExecutor;
 import org.redisson.core.RLexSortedSetReactive;
 
 public class RedissonLexSortedSetReactive extends RedissonScoredSortedSetReactive<String> implements RLexSortedSetReactive {

src/main/java/org/redisson/RedissonList.java

@@ -32,6 +32,7 @@ import org.redisson.client.protocol.convertor.BooleanNumberReplayConvertor;
 import org.redisson.client.protocol.convertor.BooleanReplayConvertor;
 import org.redisson.client.protocol.convertor.Convertor;
 import org.redisson.client.protocol.convertor.IntegerReplayConvertor;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RList;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonListReactive.java

@@ -39,6 +39,7 @@ import org.redisson.client.protocol.convertor.BooleanReplayConvertor;
 import org.redisson.client.protocol.convertor.Convertor;
 import org.redisson.client.protocol.convertor.IntegerReplayConvertor;
 import org.redisson.client.protocol.convertor.LongReplayConvertor;
+import org.redisson.command.CommandReactiveExecutor;
 import org.redisson.core.RListReactive;
 
 import reactor.core.reactivestreams.SubscriberBarrier;

src/main/java/org/redisson/RedissonLock.java

@@ -27,6 +27,7 @@ import org.redisson.client.codec.LongCodec;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.client.protocol.pubsub.PubSubType;
 import org.redisson.codec.JsonJacksonCodec;
+import org.redisson.command.CommandExecutor;
 import org.redisson.connection.PubSubConnectionEntry;
 import org.redisson.core.RLock;
 

src/main/java/org/redisson/RedissonMap.java

@@ -36,6 +36,7 @@ import org.redisson.client.protocol.convertor.BooleanReplayConvertor;
 import org.redisson.client.protocol.convertor.LongReplayConvertor;
 import org.redisson.client.protocol.convertor.NumberConvertor;
 import org.redisson.client.protocol.decoder.MapScanResult;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.Predicate;
 import org.redisson.core.RMap;
 

src/main/java/org/redisson/RedissonMapReactive.java

@@ -36,6 +36,7 @@ import org.redisson.client.protocol.convertor.BooleanReplayConvertor;
 import org.redisson.client.protocol.convertor.LongReplayConvertor;
 import org.redisson.client.protocol.convertor.NumberConvertor;
 import org.redisson.client.protocol.decoder.MapScanResult;
+import org.redisson.command.CommandReactiveExecutor;
 import org.redisson.connection.decoder.MapGetAllDecoder;
 import org.redisson.core.RMapReactive;
 

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

@@ -17,6 +17,7 @@ package org.redisson;
 
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RObject;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonObjectReactive.java

@@ -21,6 +21,7 @@ import org.reactivestreams.Subscriber;
 import org.reactivestreams.Subscription;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandReactiveExecutor;
 import org.redisson.core.RObjectReactive;
 
 import reactor.core.reactivestreams.SubscriberBarrier;

src/main/java/org/redisson/RedissonPatternTopic.java

@@ -20,6 +20,7 @@ import java.util.List;
 
 import org.redisson.client.RedisPubSubListener;
 import org.redisson.client.codec.Codec;
+import org.redisson.command.CommandExecutor;
 import org.redisson.connection.PubSubConnectionEntry;
 import org.redisson.core.PatternMessageListener;
 import org.redisson.core.PatternStatusListener;

src/main/java/org/redisson/RedissonQueue.java

@@ -19,6 +19,7 @@ import java.util.NoSuchElementException;
 
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RQueue;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonReactive.java

@@ -23,6 +23,7 @@ import java.util.UUID;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.cluster.ClusterConnectionManager;
+import org.redisson.command.CommandReactiveService;
 import org.redisson.connection.ConnectionManager;
 import org.redisson.connection.ElasticacheConnectionManager;
 import org.redisson.connection.MasterSlaveConnectionManager;

src/main/java/org/redisson/RedissonScoredSortedSet.java

@@ -30,6 +30,7 @@ import org.redisson.client.protocol.RedisCommands;
 import org.redisson.client.protocol.ScoredEntry;
 import org.redisson.client.protocol.convertor.BooleanReplayConvertor;
 import org.redisson.client.protocol.decoder.ListScanResult;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RScoredSortedSet;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonScoredSortedSetReactive.java

@@ -31,6 +31,7 @@ import org.redisson.client.protocol.RedisCommands;
 import org.redisson.client.protocol.ScoredEntry;
 import org.redisson.client.protocol.convertor.BooleanReplayConvertor;
 import org.redisson.client.protocol.decoder.ListScanResult;
+import org.redisson.command.CommandReactiveExecutor;
 import org.redisson.core.RScoredSortedSetReactive;
 
 import reactor.rx.Stream;

src/main/java/org/redisson/RedissonScript.java

@@ -22,6 +22,7 @@ import java.util.List;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommand;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RScript;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonSet.java

@@ -28,6 +28,7 @@ import org.redisson.client.protocol.RedisCommand;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.client.protocol.convertor.BooleanReplayConvertor;
 import org.redisson.client.protocol.decoder.ListScanResult;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.core.RSet;
 
 import io.netty.util.concurrent.Future;

src/main/java/org/redisson/RedissonSetReactive.java

@@ -29,6 +29,7 @@ import org.redisson.client.protocol.RedisCommand;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.client.protocol.convertor.BooleanReplayConvertor;
 import org.redisson.client.protocol.decoder.ListScanResult;
+import org.redisson.command.CommandReactiveExecutor;
 import org.redisson.core.RSetReactive;
 
 import reactor.rx.Stream;

src/main/java/org/redisson/RedissonSortedSet.java

@@ -36,6 +36,7 @@ import org.redisson.client.codec.Codec;
 import org.redisson.client.codec.LongCodec;
 import org.redisson.client.codec.StringCodec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandExecutor;
 import org.redisson.connection.ConnectionManager;
 import org.redisson.core.RSortedSet;
 

src/main/java/org/redisson/RedissonTopic.java

@@ -21,6 +21,7 @@ import java.util.List;
 import org.redisson.client.RedisPubSubListener;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandAsyncExecutor;
 import org.redisson.connection.PubSubConnectionEntry;
 import org.redisson.core.MessageListener;
 import org.redisson.core.RTopic;

src/main/java/org/redisson/RedissonTopicReactive.java

@@ -22,6 +22,7 @@ import org.reactivestreams.Publisher;
 import org.redisson.client.RedisPubSubListener;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommands;
+import org.redisson.command.CommandReactiveExecutor;
 import org.redisson.connection.PubSubConnectionEntry;
 import org.redisson.core.MessageListener;
 import org.redisson.core.RTopicReactive;

src/main/java/org/redisson/command/CommandAsyncExecutor.java

@@ -13,12 +13,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.redisson;
+package org.redisson.command;
 
 import java.net.InetSocketAddress;
 import java.util.Collection;
 import java.util.List;
 
+import org.redisson.SlotCallback;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommand;
 import org.redisson.connection.ConnectionManager;

src/main/java/org/redisson/command/CommandAsyncService.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.redisson;
+package org.redisson.command;
 
 import java.net.InetSocketAddress;
 import java.util.ArrayList;
@@ -27,6 +27,8 @@ import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicReference;
 
+import org.redisson.RedisClientResult;
+import org.redisson.SlotCallback;
 import org.redisson.client.RedisAskException;
 import org.redisson.client.RedisConnection;
 import org.redisson.client.RedisException;

src/main/java/org/redisson/command/CommandBatchAsyncService.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.redisson;
+package org.redisson.command;
 
 import java.util.ArrayList;
 import java.util.Collections;

src/main/java/org/redisson/command/CommandExecutor.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.redisson;
+package org.redisson.command;
 
 /**
  *

src/main/java/org/redisson/command/CommandReactiveExecutor.java

@@ -13,7 +13,7 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.redisson;
+package org.redisson.command;
 
 import java.net.InetSocketAddress;
 import java.util.List;

src/main/java/org/redisson/command/CommandReactiveService.java

@@ -13,12 +13,13 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.redisson;
+package org.redisson.command;
 
 import java.net.InetSocketAddress;
 import java.util.List;
 
 import org.reactivestreams.Publisher;
+import org.redisson.NettyFuturePublisher;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommand;
 import org.redisson.connection.ConnectionManager;

src/main/java/org/redisson/command/CommandSyncExecutor.java

@@ -13,11 +13,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.redisson;
+package org.redisson.command;
 
 import java.net.InetSocketAddress;
 import java.util.List;
 
+import org.redisson.SyncOperation;
 import org.redisson.client.codec.Codec;
 import org.redisson.client.protocol.RedisCommand;
 import org.redisson.connection.ConnectionManager;

src/main/java/org/redisson/command/CommandSyncService.java

@@ -13,11 +13,12 @@
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
-package org.redisson;
+package org.redisson.command;
 
 import java.net.InetSocketAddress;
 import java.util.List;
 
+import org.redisson.SyncOperation;
 import org.redisson.client.RedisAskException;
 import org.redisson.client.RedisConnection;
 import org.redisson.client.RedisException;