spring mqtt集成消息接收后如何停止重复订阅保留消息

<bean id="mqttClientFactory" class="org.springframework.integration.mqtt.core.DefaultMqttPahoClientFactory">
    <property name="serverURIs" value="tcp://mqtt.example.com:1883" />
    <property name="userName" value="username" />
    <property name="password" value="password" />
</bean>

<int-mqtt:message-driven-channel-adapter id="mqttInbound"
    client-id="clientId"
    url="tcp://mqtt.example.com:1883"
    topics="topic1,topic2"
    channel="mqttInputChannel"
    client-factory="mqttClientFactory"
    qos="1"
    completion-timeout="5000" />

<int:channel id="mqttInputChannel" />

<int:service-activator input-channel="mqttInputChannel" ref="messageHandler" method="handleMessage" />

@Component
public class MessageHandler {
    public void handleMessage(String message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message);
    }
}

<int-mqtt:message-driven-channel-adapter id="mqttInbound"
    client-id="clientId"
    url="tcp://mqtt.example.com:1883"
    topics="topic1,topic2"
    channel="mqttInputChannel"
    client-factory="mqttClientFactory"
    qos="1"
    completion-timeout="5000"
    default-retained="false" />