Class MqttClientSubscriptionsManager

Namespace

MQTTnet.Server

Assembly

MQTTnet.dll

public sealed class MqttClientSubscriptionsManager : IDisposable

Inheritance

object

MqttClientSubscriptionsManager

Implements

IDisposable

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

MqttClientSubscriptionsManager(MqttSession, MqttServerEventContainer, MqttRetainedMessagesManager, ISubscriptionChangedNotification)

public MqttClientSubscriptionsManager(MqttSession session, MqttServerEventContainer eventContainer, MqttRetainedMessagesManager retainedMessagesManager, ISubscriptionChangedNotification subscriptionChangedNotification)

Parameters

session MqttSession

eventContainer MqttServerEventContainer

retainedMessagesManager MqttRetainedMessagesManager

subscriptionChangedNotification ISubscriptionChangedNotification

Methods

CheckSubscriptions(string, ulong, MqttQualityOfServiceLevel, string)

public CheckSubscriptionsResult CheckSubscriptions(string topic, ulong topicHash, MqttQualityOfServiceLevel qualityOfServiceLevel, string senderId)

Parameters

topic string

topicHash ulong

qualityOfServiceLevel MqttQualityOfServiceLevel

senderId string

Returns

CheckSubscriptionsResult

Dispose()

public void Dispose()

Subscribe(MqttSubscribePacket, CancellationToken)

public Task<SubscribeResult> Subscribe(MqttSubscribePacket subscribePacket, CancellationToken cancellationToken)

Parameters

subscribePacket MqttSubscribePacket

cancellationToken CancellationToken

Returns

Task<SubscribeResult>

Unsubscribe(MqttUnsubscribePacket, CancellationToken)

public Task<UnsubscribeResult> Unsubscribe(MqttUnsubscribePacket unsubscribePacket, CancellationToken cancellationToken)

Parameters

unsubscribePacket MqttUnsubscribePacket

cancellationToken CancellationToken

Returns

Task<UnsubscribeResult>