We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f3efd25 commit a576cf1Copy full SHA for a576cf1
src/com/rabbitmq/client/impl/ConsumerWorkService.java
@@ -31,7 +31,8 @@ final class ConsumerWorkService {
31
32
public ConsumerWorkService(ExecutorService executor) {
33
this.privateExecutor = (executor == null);
34
- this.executor = this.executorFrom(executor);
+ this.executor = (executor == null) ? Executors.newFixedThreadPool(DEFAULT_NUM_THREADS)
35
+ : executor;
36
this.workPool = new WorkPool<Channel, Runnable>();
37
}
38
@@ -92,12 +93,4 @@ public void run() {
92
93
94
95
-
96
- private ExecutorService executorFrom(ExecutorService executor) {
97
- if (executor == null) {
98
- return Executors.newFixedThreadPool(DEFAULT_NUM_THREADS);
99
- } else {
100
- return executor;
101
- }
102
103
0 commit comments