From 0c36f27fc8e0f5e34d94994f7a58cad72436122a Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Tue, 26 Jul 2016 12:01:30 +0300
Subject: [PATCH] java.lang.UnsupportedOperationException during command batch
 usage with netty 4.0.38 and higher #557

---
 .../java/org/redisson/command/CommandBatchService.java     | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git a/src/main/java/org/redisson/command/CommandBatchService.java b/src/main/java/org/redisson/command/CommandBatchService.java
index 835cfb2db..68b56a8aa 100644
--- a/src/main/java/org/redisson/command/CommandBatchService.java
+++ b/src/main/java/org/redisson/command/CommandBatchService.java
@@ -16,9 +16,10 @@
 package org.redisson.command;
 
 import java.util.ArrayList;
+import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
-import java.util.Queue;
+import java.util.concurrent.ConcurrentLinkedQueue;
 import java.util.concurrent.ConcurrentMap;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -54,11 +55,11 @@ public class CommandBatchService extends CommandReactiveService {
 
     public static class Entry {
 
-        Queue<BatchCommandData<?, ?>> commands = PlatformDependent.newMpscQueue();
+        Collection<BatchCommandData<?, ?>> commands = new ConcurrentLinkedQueue<BatchCommandData<?,?>>();
 
         volatile boolean readOnlyMode = true;
 
-        public Queue<BatchCommandData<?, ?>> getCommands() {
+        public Collection<BatchCommandData<?, ?>> getCommands() {
             return commands;
         }