Skip to content

Commit

Permalink
Merge pull request #814 from rabbitmq/mk-higher-max-runnable-block-size
Browse files Browse the repository at this point in the history
Increase max ConsumerWorkService block size to 256
  • Loading branch information
acogoluegnes committed Jul 25, 2022
2 parents cf8ccec + 59bdcdf commit b1016c1
Showing 1 changed file with 1 addition and 1 deletion.
Expand Up @@ -27,7 +27,7 @@

final public class ConsumerWorkService {
private static final Logger LOGGER = LoggerFactory.getLogger(ConsumerWorkService.class);
private static final int MAX_RUNNABLE_BLOCK_SIZE = 16;
private static final int MAX_RUNNABLE_BLOCK_SIZE = 256;
private static final int DEFAULT_NUM_THREADS = Math.max(1, Utils.availableProcessors());
private final ExecutorService executor;
private final boolean privateExecutor;
Expand Down

0 comments on commit b1016c1

Please sign in to comment.