YangWX/MQTTnet
1
0
Fork 0
mirror of https://github.com/dotnet/MQTTnet.git synced 2026-10-20 11:45:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

Refactor exception message.

Browse Source
This commit is contained in:
Christian Kratky
2020-07-25 13:43:26 +02:00
parent e63f26789f
commit a65c015a58
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Formatter/MqttPacketFormatterAdapter.cs
+1 -1
View File
@@ -125,7 +125,7 @@ namespace MQTTnet.Formatter
// 2 byte protocol name length // 2 byte protocol name length
// at least 4 byte protocol name // at least 4 byte protocol name
// 1 byte protocol level // 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(); var protocolName = receivedMqttPacket.Body.ReadStringWithLengthPrefix();
Tests/MQTTnet.Core.Tests/MqttPacketSerializer_Tests.cs
+1 -1
View File
@@ -37,7 +37,7 @@ namespace MQTTnet.Tests
Assert.AreEqual(MqttProtocolVersion.V500, DeserializeAndDetectVersion(adapter, Serialize(p, MqttProtocolVersion.V500))); Assert.AreEqual(MqttProtocolVersion.V500, DeserializeAndDetectVersion(adapter, Serialize(p, MqttProtocolVersion.V500)));
var ex = Assert.ThrowsException<MqttProtocolViolationException>(() => DeserializeAndDetectVersion(adapter, WriterFactory().AddMqttHeader(MqttControlPacketType.Connect, new byte[0]))); var ex = Assert.ThrowsException<MqttProtocolViolationException>(() => 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<MqttProtocolViolationException>(() => DeserializeAndDetectVersion(adapter, WriterFactory().AddMqttHeader(MqttControlPacketType.Connect, new byte[7]))); ex = Assert.ThrowsException<MqttProtocolViolationException>(() => DeserializeAndDetectVersion(adapter, WriterFactory().AddMqttHeader(MqttControlPacketType.Connect, new byte[7])));
Assert.AreEqual("Protocol '' not supported.", ex.Message); Assert.AreEqual("Protocol '' not supported.", ex.Message);
ex = Assert.ThrowsException<MqttProtocolViolationException>(() => DeserializeAndDetectVersion(adapter, WriterFactory().AddMqttHeader(MqttControlPacketType.Connect, new byte[] { 255, 255, 0,0,0,0,0 }))); ex = Assert.ThrowsException<MqttProtocolViolationException>(() => DeserializeAndDetectVersion(adapter, WriterFactory().AddMqttHeader(MqttControlPacketType.Connect, new byte[] { 255, 255, 0,0,0,0,0 })));