File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change 82
82
* @author Yansong Ren
83
83
* @author Tim Bourquin
84
84
* @author Jeonggi Kim
85
+ * @author Java4ye
85
86
*
86
87
* @since 1.0
87
88
*/
@@ -613,12 +614,9 @@ private void checkListenerContainerAware() {
613
614
Assert .state (expectedQueueNames .size () == queueNames .length ,
614
615
"Listener expects us to be listening on '" + expectedQueueNames + "'; our queues: "
615
616
+ Arrays .asList (queueNames ));
616
- boolean found = false ;
617
+ boolean found = true ;
617
618
for (String queueName : queueNames ) {
618
- if (expectedQueueNames .contains (queueName )) {
619
- found = true ;
620
- }
621
- else {
619
+ if (!expectedQueueNames .contains (queueName )) {
622
620
found = false ;
623
621
break ;
624
622
}
You can’t perform that action at this time.
0 commit comments