Skip to content

Commit 064cb57

Browse files
committed
Fix new Sonar smells
1 parent 21dcdbc commit 064cb57

File tree

2 files changed

+5
-7
lines changed

2 files changed

+5
-7
lines changed

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

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,6 @@
3737
import org.springframework.integration.mqtt.core.MqttPahoClientFactory;
3838
import org.springframework.integration.mqtt.core.MqttPahoComponent;
3939
import org.springframework.integration.mqtt.event.MqttConnectionFailedEvent;
40-
import org.springframework.integration.mqtt.event.MqttIntegrationEvent;
4140
import org.springframework.integration.mqtt.event.MqttSubscribedEvent;
4241
import org.springframework.integration.mqtt.support.MqttUtils;
4342
import org.springframework.integration.support.AbstractIntegrationMessageBuilder;
@@ -46,8 +45,8 @@
4645
import org.springframework.util.Assert;
4746

4847
/**
49-
* Eclipse Paho Implementation. When consuming {@link MqttIntegrationEvent}s published by
50-
* this component use {@code MqttPahoComponent adapter = event.getSourceAsType()} to get a
48+
* Eclipse Paho Implementation. When consuming {@link org.springframework.integration.mqtt.event.MqttIntegrationEvent}s
49+
* published by this component use {@code MqttPahoComponent adapter = event.getSourceAsType()} to get a
5150
* reference, allowing you to obtain the bean name and {@link MqttConnectOptions}. This
5251
* technique allows consumption of events from both inbound and outbound endpoints in the
5352
* same event listener.
@@ -423,7 +422,7 @@ public void deliveryComplete(IMqttDeliveryToken token) {
423422
}
424423

425424
/**
426-
* Used to complete message arrival when {@link AckMode#MANUAL}.
425+
* Used to complete message arrival when {@link #manualAcks} is true.
427426
*
428427
* @since 5.3
429428
*/

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/outbound/MqttPahoMessageHandler.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@
2929
import org.springframework.integration.mqtt.core.MqttPahoClientFactory;
3030
import org.springframework.integration.mqtt.core.MqttPahoComponent;
3131
import org.springframework.integration.mqtt.event.MqttConnectionFailedEvent;
32-
import org.springframework.integration.mqtt.event.MqttIntegrationEvent;
3332
import org.springframework.integration.mqtt.event.MqttMessageDeliveredEvent;
3433
import org.springframework.integration.mqtt.event.MqttMessageSentEvent;
3534
import org.springframework.integration.mqtt.support.MqttMessageConverter;
@@ -40,8 +39,8 @@
4039
import org.springframework.util.Assert;
4140

4241
/**
43-
* Eclipse Paho Implementation. When consuming {@link MqttIntegrationEvent}s published by
44-
* this component use {@code MqttPahoComponent handler = event.getSourceAsType()} to get a
42+
* Eclipse Paho Implementation. When consuming {@link org.springframework.integration.mqtt.event.MqttIntegrationEvent}s
43+
* published by this component use {@code MqttPahoComponent handler = event.getSourceAsType()} to get a
4544
* reference, allowing you to obtain the bean name and {@link MqttConnectOptions}. This
4645
* technique allows consumption of events from both inbound and outbound endpoints in the
4746
* same event listener.

0 commit comments

Comments
 (0)