From a65c015a58eceeeb7a600b86083a291ea80f8fc0 Mon Sep 17 00:00:00 2001 From: Christian Kratky Date: Sat, 25 Jul 2020 13:43:26 +0200 Subject: [PATCH] Refactor exception message. --- Source/MQTTnet/Formatter/MqttPacketFormatterAdapter.cs | 2 +- Tests/MQTTnet.Core.Tests/MqttPacketSerializer_Tests.cs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/Source/MQTTnet/Formatter/MqttPacketFormatterAdapter.cs b/Source/MQTTnet/Formatter/MqttPacketFormatterAdapter.cs index a8dfd70d..87fb00be 100644 --- a/Source/MQTTnet/Formatter/MqttPacketFormatterAdapter.cs +++ b/Source/MQTTnet/Formatter/MqttPacketFormatterAdapter.cs @@ -125,7 +125,7 @@ namespace MQTTnet.Formatter // 2 byte protocol name length // at least 4 byte protocol name // 1 byte protocol level - throw new MqttProtocolViolationException("Mqtt Connect packet must have at least 7 bytes"); + throw new MqttProtocolViolationException("CONNECT packet must have at least 7 bytes."); } var protocolName = receivedMqttPacket.Body.ReadStringWithLengthPrefix(); diff --git a/Tests/MQTTnet.Core.Tests/MqttPacketSerializer_Tests.cs b/Tests/MQTTnet.Core.Tests/MqttPacketSerializer_Tests.cs index 14abbdf9..da3500be 100644 --- a/Tests/MQTTnet.Core.Tests/MqttPacketSerializer_Tests.cs +++ b/Tests/MQTTnet.Core.Tests/MqttPacketSerializer_Tests.cs @@ -37,7 +37,7 @@ namespace MQTTnet.Tests Assert.AreEqual(MqttProtocolVersion.V500, DeserializeAndDetectVersion(adapter, Serialize(p, MqttProtocolVersion.V500))); var ex = Assert.ThrowsException(() => DeserializeAndDetectVersion(adapter, WriterFactory().AddMqttHeader(MqttControlPacketType.Connect, new byte[0]))); - Assert.AreEqual("Mqtt Connect packet must have at least 7 bytes", ex.Message); + Assert.AreEqual("CONNECT packet must have at least 7 bytes.", ex.Message); ex = Assert.ThrowsException(() => DeserializeAndDetectVersion(adapter, WriterFactory().AddMqttHeader(MqttControlPacketType.Connect, new byte[7]))); Assert.AreEqual("Protocol '' not supported.", ex.Message); ex = Assert.ThrowsException(() => DeserializeAndDetectVersion(adapter, WriterFactory().AddMqttHeader(MqttControlPacketType.Connect, new byte[] { 255, 255, 0,0,0,0,0 })));