File tree Expand file tree Collapse file tree 2 files changed +6
-6
lines changed
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener Expand file tree Collapse file tree 2 files changed +6
-6
lines changed Original file line number Diff line number Diff line change 5353 rabbitmqVersion = project. hasProperty(' rabbitmqVersion' ) ? project. rabbitmqVersion : ' 5.7.3'
5454 rabbitmqHttpClientVersion = ' 3.2.0.RELEASE'
5555 reactorVersion = ' 3.3.0.RC1'
56- springDataCommonsVersion = ' 2.2.0.BUILD-SNAPSHOT '
56+ springDataCommonsVersion = ' 2.2.0.RC3 '
5757 springVersion = project. hasProperty(' springVersion' ) ? project. springVersion : ' 5.2.0.RC2'
5858 springRetryVersion = ' 1.2.4.RELEASE'
5959}
Original file line number Diff line number Diff line change @@ -217,14 +217,14 @@ public void setConcurrency(String concurrency) {
217217 try {
218218 int separatorIndex = concurrency .indexOf ('-' );
219219 if (separatorIndex != -1 ) {
220- int concurrentConsumers = Integer .parseInt (concurrency .substring (0 , separatorIndex ));
221- int maxConcurrentConsumers = Integer .parseInt (concurrency .substring (separatorIndex + 1 ));
222- Assert .isTrue (maxConcurrentConsumers >= concurrentConsumers ,
220+ int consumers = Integer .parseInt (concurrency .substring (0 , separatorIndex ));
221+ int maxConsumers = Integer .parseInt (concurrency .substring (separatorIndex + 1 ));
222+ Assert .isTrue (maxConsumers >= consumers ,
223223 "'maxConcurrentConsumers' value must be at least 'concurrentConsumers'" );
224224 this .concurrentConsumers = 1 ;
225225 this .maxConcurrentConsumers = null ;
226- setConcurrentConsumers (concurrentConsumers );
227- setMaxConcurrentConsumers (maxConcurrentConsumers );
226+ setConcurrentConsumers (consumers );
227+ setMaxConcurrentConsumers (maxConsumers );
228228 }
229229 else {
230230 setConcurrentConsumers (Integer .parseInt (concurrency ));
You can’t perform that action at this time.
0 commit comments