diff --git a/src/Transports/MQTT/Wolverine.MQTT/Internals/MqttTransport.cs b/src/Transports/MQTT/Wolverine.MQTT/Internals/MqttTransport.cs index 19e2293c1..3ad7f1831 100644 --- a/src/Transports/MQTT/Wolverine.MQTT/Internals/MqttTransport.cs +++ b/src/Transports/MQTT/Wolverine.MQTT/Internals/MqttTransport.cs @@ -122,7 +122,15 @@ public override Endpoint ReplyEndpoint() public async ValueTask DisposeAsync() { - await Client.StopAsync(); + try + { + // ReSharper disable once ConditionIsAlwaysTrueOrFalseAccordingToNullableAPIContract + if (Client is not null) + await Client.StopAsync(); + } + catch (ObjectDisposedException) + { + } } internal async ValueTask SubscribeToTopicAsync(string topicName, MqttListener listener, MqttTopic mqttTopic)