Spring Integration Адаптер исходящего канала mqtt публикует сообщения, когда сертификат отключен

Question

Вопрос объясняется в вопросе:

У меня есть mqtt-outbound-channel-adapter в размещенном в AWS приложении, интегрированном со службой AWS mqtt, как показано ниже:

<int-mqtt:outbound-channel-adapter id="outboundMqttChannelAdapter"                                           
                                           url="ssl://${mqtt.endpoint}"
                                           client-factory="mqttClientFactory"                                           
                                           async="true"                                           
                                           default-qos="1"/

где clientFactory настроен с помощью пользовательского SslSocketFactory, который обрабатывает сертификат.

Проблема заключается в том, что если я деактивирую сертификат AWS, приложение продолжит правильно отправлять сообщения в раздел MQTT, и только в случае потери соединения:

14:17:38.585 [MQTT Rec: 98] ERROR o.s.i.m.o.MqttPahoMessageHandler - Lost connection; will attempt reconnect on next request

и пытается восстановить соединение, тогда приложение получает правильное исключение

with root cause javax.net.ssl.SSLHandshakeException: Received fatal alert: certificate_unknown

Обратный сценарий (так реактивация сертификата) вместо этого является довольно немедленным.

Есть идеи, как предотвратить это странное поведение?