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

Add missed CollectionUtils in BlockQueueConsumer

Browse Source
This commit is contained in:
Artem Bilan
2024-01-09 11:28:25 -05:00
parent 02db80bc8a
commit aa46e3cd0a
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/listener/BlockingQueueConsumer.java
View File

@@ -27,6 +27,7 @@ import java.util.Iterator;
import java.util.LinkedHashSet;
import java.util.List;
import java.util.Map;
import java.util.Objects;
import java.util.OptionalLong;
import java.util.Set;
import java.util.concurrent.BlockingQueue;
@@ -66,6 +67,7 @@ import org.springframework.context.ApplicationEventPublisher;
import org.springframework.lang.Nullable;
import org.springframework.transaction.support.TransactionSynchronizationManager;
import org.springframework.util.Assert;
import org.springframework.util.CollectionUtils;
import org.springframework.util.ObjectUtils;
import org.springframework.util.backoff.BackOffExecution;
@@ -294,7 +296,7 @@ public class BlockingQueueConsumer {
this.transactional = transactional;
this.prefetchCount = prefetchCount;
this.defaultRequeueRejected = defaultRequeueRejected;
if (consumerArgs != null && consumerArgs.size() > 0) {
if (!CollectionUtils.isEmpty(consumerArgs)) {
this.consumerArgs.putAll(consumerArgs);
}
this.noLocal = noLocal;
@@ -309,8 +311,8 @@ public class BlockingQueueConsumer {
public Collection<String> getConsumerTags() {
return this.consumers.values().stream()
.map(c -> c.getConsumerTag())
.filter(tag -> tag != null)
.map(DefaultConsumer::getConsumerTag)
.filter(Objects::nonNull)
.collect(Collectors.toList());
}