Support for fine-grained configuration for each MqttSubscription in Spring Integration.

[demiphea]

Expected Behavior

Be able to configure MqttSubscription with fine granularity in Spring Integration, allowing for the customization of MQTT options (such as qos, noLocal, retainAsPublished, etc) for each individual or multiple topics.

Current Behavior

I'm using org.eclipse.paho.mqttv5.client in Spring Integration, and Mqttv5PahoMessageDrivenChannelAdapter lacks a method to set MqttSubscription other than creating a MqttSubscription with only default parameters(topic and qos) .

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

Lines 404 to 406 in e4ba493

	MqttSubscription[] subscriptions = IntStream.range(0, topics.length)
	.mapToObj(i -> new MqttSubscription(topics[i], requestedQos[i]))
	.toArray(MqttSubscription[]::new);

Seems like it's the same in MQTT v3 version, where there is no method provided to configure MqttSubscription.

Context

Due to limitations in my coding skills, I have currently only been able to overwrite Mqttv5PahoMessageDrivenChannelAdapter and modifying the default configuration of MqttSubscription to address this issue.

Thank you for taking the time to review this issue. I appreciate your attention to it.