GH-11538: Deprecate the Paho-based MQTT module

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/aot/MqttRuntimeHints.java

@@ -19,9 +19,13 @@
  * {@link RuntimeHintsRegistrar} for Spring Integration MQTT module.
  *
  * @author Artem Bilan
+ * @author Jaehong Park
  *
  * @since 6.1.9
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 class MqttRuntimeHints implements RuntimeHintsRegistrar {
 
 	@Override

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/config/xml/MqttMessageDrivenChannelAdapterParser.java

@@ -18,10 +18,13 @@
  *
  * @author Gary Russell
  * @author Artem Bilan
+ * @author Jaehong Park
  *
  * @since 4.0
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public class MqttMessageDrivenChannelAdapterParser extends AbstractChannelAdapterParser {
 
 	@Override

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/config/xml/MqttNamespaceHandler.java

@@ -10,10 +10,13 @@
  * The namespace handler for the MqttAdapter namespace.
  *
  * @author Gary Russell
+ * @author Jaehong Park
  *
  * @since 4.0
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public class MqttNamespaceHandler extends AbstractIntegrationNamespaceHandler {
 
 	@Override

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/config/xml/MqttOutboundChannelAdapterParser.java

@@ -18,9 +18,12 @@
  * The parser for the MqttAdapter Outbound Channel Adapter.
  *
  * @author Gary Russell
+ * @author Jaehong Park
  * @since 4.0
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public class MqttOutboundChannelAdapterParser extends AbstractOutboundChannelAdapterParser {
 
 	@Override

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/config/xml/MqttParserUtils.java

@@ -23,10 +23,13 @@
  *
  * @author Gary Russell
  * @author Artem Bilan
+ * @author Jaehong Park
  *
  * @since 4.0
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 final class MqttParserUtils {
 
 	private MqttParserUtils() {

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/core/AbstractMqttClientManager.java

@@ -30,9 +30,13 @@
  * @author Artem Vozhdayenko
  * @author Artem Bilan
  * @author Christian Tzolov
+ * @author Jaehong Park
  *
  * @since 6.0
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public abstract class AbstractMqttClientManager<T, C> implements ClientManager<T, C>, ApplicationEventPublisherAware {
 
 	protected final Log logger = LogFactory.getLog(this.getClass()); // NOSONAR

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/core/ClientManager.java

@@ -20,9 +20,13 @@
  * @author Artem Bilan
  * @author Jiri Soucek
  * @author Jiandong Ma
+ * @author Jaehong Park
  *
  * @since 6.0
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public interface ClientManager<T, C> extends SmartLifecycle, MqttComponent<C> {
 
 	/**

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/core/DefaultMqttPahoClientFactory.java

@@ -20,10 +20,13 @@
  *
  * @author Gary Russell
  * @author Gunnar Hillert
+ * @author Jaehong Park
  *
  * @since 4.0
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public class DefaultMqttPahoClientFactory implements MqttPahoClientFactory {
 
 	private MqttConnectOptions options = new MqttConnectOptions();
@@ -65,6 +68,9 @@ public MqttConnectOptions getConnectionOptions() {
 		return this.options;
 	}
 
+	/**
+	 * An MQTT will message.
+	 */
 	public static class Will {
 
 		private final String topic;

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/core/MqttComponent.java

@@ -12,9 +12,12 @@
  * @param <T> The connection information type.
  *
  * @author Gary Russell
+ * @author Jaehong Park
  * @since 2.5
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public interface MqttComponent<T> extends BeanNameAware {
 
 	/**

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/core/MqttPahoClientFactory.java

@@ -12,9 +12,12 @@
 
 /**
  * @author Gary Russell
+ * @author Jaehong Park
  * @since 4.0
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public interface MqttPahoClientFactory {
 
 	/**

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/core/MqttPahoComponent.java

@@ -10,9 +10,12 @@
  * An extension of {@link MqttComponent} for Eclipse Paho components.
  *
  * @author Gary Russell
+ * @author Jaehong Park
  * @since 5.4
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public interface MqttPahoComponent extends MqttComponent<MqttConnectOptions> {
 
 	@Override

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/core/Mqttv3ClientManager.java

@@ -28,9 +28,13 @@
  * @author Artem Bilan
  * @author Christian Tzolov
  * @author Jiri Soucek
+ * @author Jaehong Park
  *
  * @since 6.0
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public class Mqttv3ClientManager
 		extends AbstractMqttClientManager<IMqttAsyncClient, MqttConnectOptions>
 		implements MqttCallbackExtended {

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/core/Mqttv5ClientManager.java

@@ -31,9 +31,13 @@
  * @author Artem Bilan
  * @author Christian Tzolov
  * @author Jiri Soucek
+ * @author Jaehong Park
  *
  * @since 6.0
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public class Mqttv5ClientManager
 		extends AbstractMqttClientManager<IMqttAsyncClient, MqttConnectionOptions>
 		implements MqttCallback {

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/event/MqttConnectionFailedEvent.java

@@ -12,11 +12,13 @@
  *
  * @author Gary Russell
  * @author Artem Bilan
+ * @author Jaehong Park
  *
  * @since 4.2.2
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
-@SuppressWarnings("serial")
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings({"serial", "removal"})
 public class MqttConnectionFailedEvent extends MqttIntegrationEvent {
 
 	public MqttConnectionFailedEvent(Object source) {

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/event/MqttIntegrationEvent.java

@@ -15,10 +15,13 @@
  *
  * @author Gary Russell
  * @author Artem Bilan
+ * @author Jaehong Park
  *
  * @since 4.1
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
-@SuppressWarnings("serial")
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings({"serial", "removal"})
 public abstract class MqttIntegrationEvent extends IntegrationEvent {
 
 	public MqttIntegrationEvent(Object source) {

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/event/MqttMessageDeliveredEvent.java

@@ -9,10 +9,12 @@
  * was delivered.
  *
  * @author Gary Russell
+ * @author Jaehong Park
  * @since 4.1
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
-@SuppressWarnings("serial")
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings({"serial", "removal"})
 public class MqttMessageDeliveredEvent extends MqttMessageDeliveryEvent {
 
 	public MqttMessageDeliveredEvent(Object source, int messageId, String clientId,

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/event/MqttMessageDeliveryEvent.java

@@ -9,10 +9,12 @@
  * {@link #clientId} and {@link #clientInstance} can be used to correlate events.
  *
  * @author Gary Russell
+ * @author Jaehong Park
  * @since 4.1
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
-@SuppressWarnings("serial")
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings({"serial", "removal"})
 public abstract class MqttMessageDeliveryEvent extends MqttIntegrationEvent {
 
 	private final int messageId;

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/event/MqttMessageNotDeliveredEvent.java

@@ -11,10 +11,13 @@
  * was not delivered on publish operation.
  *
  * @author Artem Bilan
+ * @author Jaehong Park
  *
  * @since 6.4
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public class MqttMessageNotDeliveredEvent extends MqttMessageDeliveryEvent {
 
 	@Serial

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/event/MqttMessageSentEvent.java

@@ -11,10 +11,12 @@
  * has been sent.
  *
  * @author Gary Russell
+ * @author Jaehong Park
  * @since 4.1
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
-@SuppressWarnings("serial")
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings({"serial", "removal"})
 public class MqttMessageSentEvent extends MqttMessageDeliveryEvent {
 
 	private final Message<?> message;

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/event/MqttProtocolErrorEvent.java

@@ -10,12 +10,15 @@
  * The even representing an MQTT error occurred during client interaction.
  *
  * @author Artem Bilan
+ * @author Jaehong Park
  *
  * @since 5.5.5
  *
  * @see org.eclipse.paho.mqttv5.client.MqttCallback#mqttErrorOccurred(MqttException)
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
-@SuppressWarnings("serial")
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings({"serial", "removal"})
 public class MqttProtocolErrorEvent extends MqttIntegrationEvent {
 
 	public MqttProtocolErrorEvent(Object source, MqttException exception) {

spring-integration-mqtt/src/main/java/org/springframework/integration/mqtt/event/MqttSubscribedEvent.java

@@ -6,10 +6,12 @@
 
 /**
  * @author Gary Russell
+ * @author Jaehong Park
  * @since 4.2.2
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
-@SuppressWarnings("serial")
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings({"serial", "removal"})
 public class MqttSubscribedEvent extends MqttIntegrationEvent {
 
 	private final String message;

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

@@ -40,12 +40,15 @@
  * @author Artem Vozhdayenko
  * @author Jiri Soucek
  * @author Glenn Renfro
+ * @author Jaehong Park
  *
  * @since 4.0
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
 @ManagedResource
 @IntegrationManagedResource
+@SuppressWarnings("removal")
 public abstract class AbstractMqttMessageDrivenChannelAdapter<T, C> extends MessageProducerSupport
 		implements ApplicationEventPublisherAware, ClientManager.ConnectCallback {
 

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

@@ -49,10 +49,13 @@
  * @author Artem Bilan
  * @author Artem Vozhdayenko
  * @author Glenn Renfro
+ * @author Jaehong Park
  *
  * @since 4.0
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public class MqttPahoMessageDrivenChannelAdapter
 		extends AbstractMqttMessageDrivenChannelAdapter<IMqttAsyncClient, MqttConnectOptions>
 		implements MqttCallbackExtended, MqttPahoComponent {

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

@@ -76,10 +76,13 @@
  * @author Matthias Thoma
  * @author Glenn Renfro
  * @author Goutam Adwant
+ * @author Jaehong Park
  *
  * @since 5.5.5
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public class Mqttv5PahoMessageDrivenChannelAdapter
 		extends AbstractMqttMessageDrivenChannelAdapter<IMqttAsyncClient, MqttConnectionOptions>
 		implements MqttCallback, MqttComponent<MqttConnectionOptions> {

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

@@ -38,10 +38,13 @@
  * @author Gary Russell
  * @author Artem Bilan
  * @author Artem Vozhdayenko
+ * @author Jaehong Park
  *
  * @since 4.0
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public abstract class AbstractMqttMessageHandler<T, C> extends AbstractMessageHandler
 		implements ManageableLifecycle, ApplicationEventPublisherAware {
 

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

@@ -39,10 +39,13 @@
  * @author Artem Bilan
  * @author Artem Vozhdayenko
  * @author Christian Tzolov
+ * @author Jaehong Park
  *
  * @since 4.0
- *
+ * @deprecated since 7.2 in favor of the {@code spring-integration-mqtt-client} module.
  */
+@Deprecated(since = "7.2", forRemoval = true)
+@SuppressWarnings("removal")
 public class MqttPahoMessageHandler extends AbstractMqttMessageHandler<IMqttAsyncClient, MqttConnectOptions>
 		implements MqttCallback, MqttPahoComponent {