From 6d0e0a63624f2926f27bcadb3485cc5618f1ebf6 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Fri, 23 Dec 2016 16:34:55 +0300
Subject: [PATCH] RSortedSet.removeAsync and RSortedSet.addAsync don't work

---
 .../src/main/java/org/redisson/RedissonSortedSet.java  | 10 +++-------
 .../src/main/java/org/redisson/api/RSortedSet.java     |  6 ++++++
 2 files changed, 9 insertions(+), 7 deletions(-)

diff --git a/redisson/src/main/java/org/redisson/RedissonSortedSet.java b/redisson/src/main/java/org/redisson/RedissonSortedSet.java
index c33514b2e..6d5a9ae8e 100644
--- a/redisson/src/main/java/org/redisson/RedissonSortedSet.java
+++ b/redisson/src/main/java/org/redisson/RedissonSortedSet.java
@@ -39,13 +39,11 @@ import org.redisson.client.protocol.RedisCommands;
 import org.redisson.command.CommandExecutor;
 import org.redisson.misc.RPromise;
 
-import io.netty.channel.EventLoopGroup;
-
 /**
  *
  * @author Nikita Koksharov
  *
- * @param <V> value
+ * @param <V> value type
  */
 public class RedissonSortedSet<V> extends RedissonObject implements RSortedSet<V> {
 
@@ -251,7 +249,7 @@ public class RedissonSortedSet<V> extends RedissonObject implements RSortedSet<V
 
     public RFuture<Boolean> addAsync(final V value) {
         final RPromise<Boolean> promise = newPromise();
-        commandExecutor.getConnectionManager().getGroup().execute(new Runnable() {
+        commandExecutor.getConnectionManager().getExecutor().execute(new Runnable() {
             public void run() {
                 try {
                     boolean res = add(value);
@@ -266,10 +264,8 @@ public class RedissonSortedSet<V> extends RedissonObject implements RSortedSet<V
 
     @Override
     public RFuture<Boolean> removeAsync(final V value) {
-        EventLoopGroup group = commandExecutor.getConnectionManager().getGroup();
         final RPromise<Boolean> promise = newPromise();
-
-        group.execute(new Runnable() {
+        commandExecutor.getConnectionManager().getExecutor().execute(new Runnable() {
             @Override
             public void run() {
                 try {
diff --git a/redisson/src/main/java/org/redisson/api/RSortedSet.java b/redisson/src/main/java/org/redisson/api/RSortedSet.java
index df8e3281f..315e010f6 100644
--- a/redisson/src/main/java/org/redisson/api/RSortedSet.java
+++ b/redisson/src/main/java/org/redisson/api/RSortedSet.java
@@ -19,6 +19,12 @@ import java.util.Comparator;
 import java.util.Set;
 import java.util.SortedSet;
 
+/**
+ * 
+ * @author Nikita Koksharov
+ *
+ * @param <V> value type
+ */
 public interface RSortedSet<V> extends SortedSet<V>, RObject {
 
     Set<V> readAll();