mirror of
https://github.com/dotnet/MQTTnet.git
synced 2026-10-30 18:56:30 +08:00
Made deliveryCount a local variable.
This commit is contained in:
@@ -29,7 +29,5 @@ namespace MQTTnet
|
|||||||
public byte[] CorrelationData { get; set; }
|
public byte[] CorrelationData { get; set; }
|
||||||
|
|
||||||
public List<uint> SubscriptionIdentifiers { get; set; }
|
public List<uint> SubscriptionIdentifiers { get; set; }
|
||||||
|
|
||||||
internal uint DeliveryCount { get; set; }
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -56,8 +56,6 @@ namespace MQTTnet.Server
|
|||||||
|
|
||||||
_logger.Verbose("Queued application message with topic '{0}' (ClientId: {1}).", applicationMessage.Topic, ClientId);
|
_logger.Verbose("Queued application message with topic '{0}' (ClientId: {1}).", applicationMessage.Topic, ClientId);
|
||||||
|
|
||||||
applicationMessage.DeliveryCount++;
|
|
||||||
|
|
||||||
ApplicationMessagesQueue.Enqueue(applicationMessage, senderClientId, checkSubscriptionsResult.QualityOfServiceLevel, isRetainedApplicationMessage);
|
ApplicationMessagesQueue.Enqueue(applicationMessage, senderClientId, checkSubscriptionsResult.QualityOfServiceLevel, isRetainedApplicationMessage);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -224,7 +224,7 @@ namespace MQTTnet.Server
|
|||||||
await _retainedMessagesManager.HandleMessageAsync(sender?.ClientId, applicationMessage).ConfigureAwait(false);
|
await _retainedMessagesManager.HandleMessageAsync(sender?.ClientId, applicationMessage).ConfigureAwait(false);
|
||||||
}
|
}
|
||||||
|
|
||||||
applicationMessage.DeliveryCount = 0;
|
var deliveryCount = 0;
|
||||||
|
|
||||||
foreach (var clientSession in _sessions.Values)
|
foreach (var clientSession in _sessions.Values)
|
||||||
{
|
{
|
||||||
@@ -232,9 +232,11 @@ namespace MQTTnet.Server
|
|||||||
applicationMessage,
|
applicationMessage,
|
||||||
sender?.ClientId,
|
sender?.ClientId,
|
||||||
false);
|
false);
|
||||||
|
|
||||||
|
deliveryCount++;
|
||||||
}
|
}
|
||||||
|
|
||||||
if (applicationMessage.DeliveryCount == 0)
|
if (deliveryCount == 0)
|
||||||
{
|
{
|
||||||
if (_options.UndeliveredMessageInterceptor == null)
|
if (_options.UndeliveredMessageInterceptor == null)
|
||||||
{
|
{
|
||||||
|
|||||||
Reference in New Issue
Block a user