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

RMI & MQTT Sonar fixes

Browse Source
This commit is contained in:
Artem Bilan
2018-10-26 13:27:42 -04:00
parent 1555a13ee5
commit fef0a4db03
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/inbound/MqttPahoMessageDrivenChannelAdapter.java
View File

@@ -57,10 +57,10 @@ public class MqttPahoMessageDrivenChannelAdapter extends AbstractMqttMessageDriv
private final MqttPahoClientFactory clientFactory;
private long completionTimeout = DEFAULT_COMPLETION_TIMEOUT;
private int recoveryInterval = DEFAULT_RECOVERY_INTERVAL;
private volatile long completionTimeout = DEFAULT_COMPLETION_TIMEOUT;
private volatile IMqttClient client;
private volatile ScheduledFuture<?> reconnectFuture;

2
spring-integration-rmi/src/main/java/org/springframework/integration/rmi/RmiInboundGateway.java
View File

@@ -22,6 +22,7 @@ import org.springframework.beans.factory.InitializingBean;
import org.springframework.integration.gateway.MessagingGatewaySupport;
import org.springframework.integration.gateway.RequestReplyExchanger;
import org.springframework.integration.support.context.NamedComponent;
import org.springframework.lang.Nullable;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.remoting.rmi.RmiServiceExporter;
@@ -118,6 +119,7 @@ public class RmiInboundGateway extends MessagingGatewaySupport
}
@Override
@Nullable
public Message<?> exchange(Message<?> message) {
if (this.expectReply) {
return sendAndReceiveMessage(message);