diff --git a/Source/MQTTnet/Client/MqttClient.cs b/Source/MQTTnet/Client/MqttClient.cs index 52c5cb8c..2cb737f2 100644 --- a/Source/MQTTnet/Client/MqttClient.cs +++ b/Source/MQTTnet/Client/MqttClient.cs @@ -930,7 +930,7 @@ namespace MQTTnet.Client static void ThrowNotConnected() { - throw new MqttCommunicationException("The client is not connected."); + throw new MqttClientNotConnectedException(); } void TryInitiateDisconnect() diff --git a/Source/MQTTnet/Exceptions/MqttClientNotConnectedException.cs b/Source/MQTTnet/Exceptions/MqttClientNotConnectedException.cs new file mode 100644 index 00000000..716ead70 --- /dev/null +++ b/Source/MQTTnet/Exceptions/MqttClientNotConnectedException.cs @@ -0,0 +1,19 @@ +// Licensed to the .NET Foundation under one or more agreements. +// The .NET Foundation licenses this file to you under the MIT license. +// See the LICENSE file in the project root for more information. + +using System; + +namespace MQTTnet.Exceptions +{ + public class MqttClientNotConnectedException : MqttCommunicationException + { + public MqttClientNotConnectedException() : base("The MQTT client is not connected.") + { + } + + public MqttClientNotConnectedException(Exception innerException) : base("The MQTT client is not connected.", innerException) + { + } + } +}