jdeppe-pivotal commented on a change in pull request #5420:
URL: https://github.com/apache/geode/pull/5420#discussion_r468823814
##########
File path:
geode-redis/src/main/java/org/apache/geode/redis/internal/netty/ExecutionHandlerContext.java
##########
@@ -59,17 +60,21 @@
public class ExecutionHandlerContext extends ChannelInboundHandlerAdapter {
private static final Logger logger = LogService.getLogger();
+ private static final Command TERMINATE_COMMAND = new Command();
private final Client client;
private final Channel channel;
private final RegionProvider regionProvider;
private final PubSub pubsub;
- private final EventLoopGroup subscriberGroup;
private final ByteBufAllocator byteBufAllocator;
private final byte[] authPassword;
private final Supplier<Boolean> allowUnsupportedSupplier;
private final Runnable shutdownInvoker;
private final RedisStats redisStats;
+ private final ExecutorService backgroundExecutor;
+ private final int MAX_QUEUED_COMMANDS = 100;
+ private final LinkedBlockingQueue<Command> commandQueue =
Review comment:
I've made it configurable via a system property and defaulted it to
`1000`.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
