pubsub handling moved to separate package

src/main/java/org/redisson/client/RedisClient.java

@@ -21,9 +21,9 @@ import java.util.concurrent.ExecutionException;
 import org.redisson.client.handler.RedisCommandsQueue;
 import org.redisson.client.handler.RedisDecoder;
 import org.redisson.client.handler.RedisEncoder;
-import org.redisson.client.protocol.PubSubStatusMessage;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.client.protocol.StringCodec;
+import org.redisson.client.protocol.pubsub.PubSubStatusMessage;
 
 import io.netty.bootstrap.Bootstrap;
 import io.netty.channel.Channel;

src/main/java/org/redisson/client/RedisPubSubConnection.java

@@ -5,16 +5,16 @@ import java.util.concurrent.ConcurrentLinkedQueue;
 import org.redisson.client.handler.RedisData;
 import org.redisson.client.protocol.Codec;
 import org.redisson.client.protocol.Decoder;
-import org.redisson.client.protocol.MultiDecoder;
-import org.redisson.client.protocol.PubSubStatusMessage;
-import org.redisson.client.protocol.PubSubStatusDecoder;
-import org.redisson.client.protocol.PubSubMessage;
 import org.redisson.client.protocol.RedisCommand;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.client.protocol.StringCodec;
-import org.redisson.client.protocol.PubSubMessageDecoder;
-import org.redisson.client.protocol.PubSubPatternMessage;
-import org.redisson.client.protocol.PubSubPatternMessageDecoder;
+import org.redisson.client.protocol.pubsub.MultiDecoder;
+import org.redisson.client.protocol.pubsub.PubSubMessage;
+import org.redisson.client.protocol.pubsub.PubSubMessageDecoder;
+import org.redisson.client.protocol.pubsub.PubSubPatternMessage;
+import org.redisson.client.protocol.pubsub.PubSubPatternMessageDecoder;
+import org.redisson.client.protocol.pubsub.PubSubStatusDecoder;
+import org.redisson.client.protocol.pubsub.PubSubStatusMessage;
 
 import io.netty.channel.Channel;
 import io.netty.channel.ChannelFuture;

src/main/java/org/redisson/client/handler/RedisData.java

@@ -19,8 +19,8 @@ import java.util.concurrent.atomic.AtomicBoolean;
 
 import org.redisson.client.protocol.Codec;
 import org.redisson.client.protocol.Decoder;
-import org.redisson.client.protocol.MultiDecoder;
 import org.redisson.client.protocol.RedisCommand;
+import org.redisson.client.protocol.pubsub.MultiDecoder;
 
 import io.netty.util.concurrent.Promise;
 

src/main/java/org/redisson/client/handler/RedisDecoder.java

@@ -24,9 +24,9 @@ import org.redisson.client.RedisException;
 import org.redisson.client.RedisPubSubConnection;
 import org.redisson.client.handler.RedisCommandsQueue.QueueCommands;
 import org.redisson.client.protocol.Decoder;
-import org.redisson.client.protocol.MultiDecoder;
-import org.redisson.client.protocol.PubSubMessage;
-import org.redisson.client.protocol.PubSubPatternMessage;
+import org.redisson.client.protocol.pubsub.MultiDecoder;
+import org.redisson.client.protocol.pubsub.PubSubMessage;
+import org.redisson.client.protocol.pubsub.PubSubPatternMessage;
 
 import io.netty.buffer.ByteBuf;
 import io.netty.channel.ChannelHandlerContext;

src/main/java/org/redisson/client/protocol/RedisCommand.java

@@ -15,6 +15,8 @@
  */
 package org.redisson.client.protocol;
 
+import org.redisson.client.protocol.pubsub.MultiDecoder;
+
 public class RedisCommand<R> {
 
     private final String name;

src/main/java/org/redisson/client/protocol/RedisCommands.java

@@ -15,6 +15,9 @@
  */
 package org.redisson.client.protocol;
 
+import org.redisson.client.protocol.pubsub.PubSubStatusDecoder;
+import org.redisson.client.protocol.pubsub.PubSubStatusMessage;
+
 public interface RedisCommands {
 
     RedisStrictCommand<String> AUTH = new RedisStrictCommand<String>("AUTH", new StringReplayDecoder());

src/main/java/org/redisson/client/protocol/RedisStrictCommand.java

@@ -1,5 +1,7 @@
 package org.redisson.client.protocol;
 
+import org.redisson.client.protocol.pubsub.MultiDecoder;
+
 public class RedisStrictCommand<T> extends RedisCommand<T> {
 
     public RedisStrictCommand(String name, MultiDecoder<T> replayMultiDecoder, int... encodeParamIndexes) {

src/main/java/org/redisson/client/protocol/pubsub/MultiDecoder.java

@@ -1,7 +1,9 @@
-package org.redisson.client.protocol;
+package org.redisson.client.protocol.pubsub;
 
 import java.util.List;
 
+import org.redisson.client.protocol.Decoder;
+
 public interface MultiDecoder<T> extends Decoder<Object> {
 
     T decode(List<Object> parts);

src/main/java/org/redisson/client/protocol/pubsub/PubSubMessage.java

@@ -1,4 +1,4 @@
-package org.redisson.client.protocol;
+package org.redisson.client.protocol.pubsub;
 
 public class PubSubMessage {
 

src/main/java/org/redisson/client/protocol/pubsub/PubSubMessageDecoder.java

@@ -1,4 +1,4 @@
-package org.redisson.client.protocol;
+package org.redisson.client.protocol.pubsub;
 
 import java.util.List;
 

src/main/java/org/redisson/client/protocol/pubsub/PubSubPatternMessage.java

@@ -1,4 +1,4 @@
-package org.redisson.client.protocol;
+package org.redisson.client.protocol.pubsub;
 
 public class PubSubPatternMessage {
 

src/main/java/org/redisson/client/protocol/pubsub/PubSubPatternMessageDecoder.java

@@ -1,4 +1,4 @@
-package org.redisson.client.protocol;
+package org.redisson.client.protocol.pubsub;
 
 import java.util.List;
 

src/main/java/org/redisson/client/protocol/pubsub/PubSubStatusDecoder.java

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

src/main/java/org/redisson/client/protocol/pubsub/PubSubStatusMessage.java

@@ -1,4 +1,4 @@
-package org.redisson.client.protocol;
+package org.redisson.client.protocol.pubsub;
 
 import java.util.List;