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

Add PackageIdentifier to MqttApplicationMessageReceivedEventArgs (#1466)

Browse Source 
Provide `PackageIdentifier` as read only property in `MqttApplicationMessageReceivedEventArgs`
This commit is contained in:
Alexander Köpke
2022-07-23 10:37:57 +02:00
committed by GitHub
parent 13762eedd4
commit 6c29ea56fc
1 changed files with 8 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
Source/MQTTnet/Client/Receiving/MqttApplicationMessageReceivedEventArgs.cs
+8 -2
View File
@@ -25,6 +25,7 @@ namespace MQTTnet.Client
ClientId = clientId; ClientId = clientId;
ApplicationMessage = applicationMessage ?? throw new ArgumentNullException(nameof(applicationMessage)); ApplicationMessage = applicationMessage ?? throw new ArgumentNullException(nameof(applicationMessage));
PublishPacket = publishPacket; PublishPacket = publishPacket;
PacketIdentifier = publishPacket.PacketIdentifier;
_acknowledgeHandler = acknowledgeHandler; _acknowledgeHandler = acknowledgeHandler;
} }
@@ -62,12 +63,17 @@ namespace MQTTnet.Client
public bool IsHandled { get; set; } public bool IsHandled { get; set; }
/// <summary> /// <summary>
/// Gets ir sets whether the library should send MQTT ACK packets automatically if required. /// Gets or sets whether the library should send MQTT ACK packets automatically if required.
/// </summary> /// </summary>
public bool AutoAcknowledge { get; set; } = true; public bool AutoAcknowledge { get; set; } = true;
public object Tag { get; set; } public object Tag { get; set; }
/// <summary>
/// Gets the indentifier of MQTT packet
/// </summary>
public ushort PacketIdentifier { get; }
public Task AcknowledgeAsync(CancellationToken cancellationToken) public Task AcknowledgeAsync(CancellationToken cancellationToken)
{ {
if (_acknowledgeHandler == null) if (_acknowledgeHandler == null)