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

Address Sonar reports for recent commits

Browse Source
This commit is contained in:
Gary Russell
2018-11-08 12:29:22 -05:00
committed by Artem Bilan
parent 648aeb8e96
commit 433ef4c4aa
4 changed files with 11 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
spring-integration-redis/src/main/java/org/springframework/integration/redis/outbound/RedisPublishingMessageHandler.java
View File

@@ -102,12 +102,13 @@ public class RedisPublishingMessageHandler extends AbstractMessageHandler {
protected void handleMessageInternal(Message<?> message) {
String topic = this.topicExpression.getValue(this.evaluationContext, message, String.class);
Object value = this.messageConverter.fromMessage(message, Object.class);
// TODO: 5.2 assert both not null
if (value instanceof byte[]) {
this.template.convertAndSend(topic, value);
this.template.convertAndSend(topic, value); // NOSONAR
}
else {
this.template.convertAndSend(topic, ((RedisSerializer<Object>) this.serializer).serialize(value));
this.template.convertAndSend(topic, ((RedisSerializer<Object>) this.serializer).serialize(value)); // NOSONAR
}
}

5
spring-integration-redis/src/main/java/org/springframework/integration/redis/outbound/RedisQueueOutboundChannelAdapter.java
View File

@@ -125,11 +125,12 @@ public class RedisQueueOutboundChannelAdapter extends AbstractMessageHandler {
}
String queueName = this.queueNameExpression.getValue(this.evaluationContext, message, String.class);
// TODO: 5.2 assert both not null
if (this.leftPush) {
this.template.boundListOps(queueName).leftPush(value);
this.template.boundListOps(queueName).leftPush(value); // NOSONAR
}
else {
this.template.boundListOps(queueName).rightPush(value);
this.template.boundListOps(queueName).rightPush(value); // NOSONAR
}
}