Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INTEXT-145 Do not set the queue to fair

Browse Source
This commit is contained in:
Marius Bogoevici
2015-03-09 03:25:03 -04:00
committed by Artem Bilan
parent aef99fcd9d
commit da0f730298
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-kafka/src/main/java/org/springframework/integration/kafka/listener/QueueingMessageListenerInvoker.java
View File

@@ -60,7 +60,7 @@ class QueueingMessageListenerInvoker implements Runnable, Lifecycle {
}
this.offsetManager = offsetManager;
this.errorHandler = errorHandler;
this.messages = new ArrayBlockingQueue<KafkaMessage>(capacity, true);
this.messages = new ArrayBlockingQueue<KafkaMessage>(capacity);
}
/**