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

Fix Sonar Issue

Browse Source
This commit is contained in:
Gary Russell
2022-04-20 16:25:23 -04:00
parent baea1221f6
commit c5548464d4
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
spring-rabbit/src/main/java/org/springframework/amqp/rabbit/core/RabbitTemplate.java
View File

@@ -1944,6 +1944,7 @@ public class RabbitTemplate extends RabbitAccessor // NOSONAR type line count
@Nullable
private Message doSendAndReceiveWithDirect(String exchange, String routingKey, Message message,
@Nullable CorrelationData correlationData) {
ConnectionFactory connectionFactory = obtainTargetConnectionFactory(
this.sendConnectionFactorySelectorExpression, message);
if (this.usePublisherConnection && connectionFactory.getPublisherConnectionFactory() != null) {
@@ -1957,7 +1958,7 @@ public class RabbitTemplate extends RabbitAccessor // NOSONAR type line count
boolean cancelConsumer = false;
try {
Channel channel = channelHolder.getChannel();
if (isPublisherConfirmsOrReturns(connectionFactory)) {
if (isPublisherConfirmsOrReturns(connectionFactory)) { // NOSONAR false positive NP dereference
addListener(channel);
}
Message reply = doSendAndReceiveAsListener(exchange, routingKey, message, correlationData, channel,