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

Merge branch 'master' into 1311-how-does-mqttclient-specify-the-network-card-to-send-data

Browse Source
This commit is contained in:
Christian
2022-07-23 11:03:06 +02:00
parent d3848d8cb0 a94776eeea
commit 57745e8324
3 changed files with 10 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files
.github/workflows/ReleaseNotes.md
+1 -9
View File
@@ -1,9 +1 @@
* [Core] Updated nuget packages. * [Client] Added support for passing the local endpoint which should be used (network card).
* [Core] The option _IgnoreCertificateChainErrors_ is now respected (thanks to @GodVenn, #1447).
* [ManagedClient] The managed client now sends the entire topic filter including new MQTTv5 properties when subscribing.
* [ManagedClient] Fixed wrong firing of _ApplicationMessageSkippedAsync_ event (thanks to @quackgizmo, #1460).
* [Server] Fixed reporting of _MaximumQoS_ in _ConnAck_ packet (MQTTv5 only) (#1442).
* [Server] Fix cross thread issue in session message storage for QoS 1 and 2.
* [Server] The event _ClientSubscribedTopicAsync_ is now fired after the subscription is completely processed internally (#1435).
* [Server] Improved CPU usage on lower end machines (#788).
* [Client] Added support for passing the local endpoint which should be used (network card).
.github/workflows/ci.yml
+1 -1
View File
@@ -3,7 +3,7 @@ name: CI
on: [push, pull_request] on: [push, pull_request]
env: env:
VERSION: "4.0.2.${{github.run_number}}" VERSION: "4.1.0.${{github.run_number}}"
jobs: jobs:
build: build:
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)