Class MqttClientSessionsManager

Namespace

MQTTnet.Server

Assembly

MQTTnet.dll

public sealed class MqttClientSessionsManager : ISubscriptionChangedNotification, IDisposable

Inheritance

object

MqttClientSessionsManager

Implements

ISubscriptionChangedNotification

IDisposable

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

MqttClientSessionsManager(MqttServerOptions, MqttRetainedMessagesManager, MqttServerEventContainer, IMqttNetLogger)

public MqttClientSessionsManager(MqttServerOptions options, MqttRetainedMessagesManager retainedMessagesManager, MqttServerEventContainer eventContainer, IMqttNetLogger logger)

Parameters

options MqttServerOptions

retainedMessagesManager MqttRetainedMessagesManager

eventContainer MqttServerEventContainer

logger IMqttNetLogger

Methods

CloseAllConnections(MqttServerClientDisconnectOptions)

public Task CloseAllConnections(MqttServerClientDisconnectOptions options)

Parameters

options MqttServerClientDisconnectOptions

Returns

Task

DeleteSessionAsync(string)

public Task DeleteSessionAsync(string clientId)

Parameters

clientId string

Returns

Task

DispatchApplicationMessage(string, IDictionary, MqttApplicationMessage, CancellationToken)

public Task<DispatchApplicationMessageResult> DispatchApplicationMessage(string senderId, IDictionary senderSessionItems, MqttApplicationMessage applicationMessage, CancellationToken cancellationToken)

Parameters

senderId string

senderSessionItems IDictionary

applicationMessage MqttApplicationMessage

cancellationToken CancellationToken

Returns

Task<DispatchApplicationMessageResult>

Dispose()

public void Dispose()

GetClient(string)

public MqttClient GetClient(string id)

Parameters

id string

Returns

MqttClient

GetClients()

public List<MqttClient> GetClients()

Returns

List<MqttClient>

GetClientsStatus()

public Task<IList<MqttClientStatus>> GetClientsStatus()

Returns

Task<IList<MqttClientStatus>>

GetSessionsStatus()

public Task<IList<MqttSessionStatus>> GetSessionsStatus()

Returns

Task<IList<MqttSessionStatus>>

HandleClientConnectionAsync(IMqttChannelAdapter, CancellationToken)

public Task HandleClientConnectionAsync(IMqttChannelAdapter channelAdapter, CancellationToken cancellationToken)

Parameters

channelAdapter IMqttChannelAdapter

cancellationToken CancellationToken

Returns

Task

OnSubscriptionsAdded(MqttSession, List<string>)

public void OnSubscriptionsAdded(MqttSession clientSession, List<string> topics)

Parameters

clientSession MqttSession

topics List<string>

OnSubscriptionsRemoved(MqttSession, List<string>)

public void OnSubscriptionsRemoved(MqttSession clientSession, List<string> subscriptionTopics)

Parameters

clientSession MqttSession

subscriptionTopics List<string>

Start()

public void Start()

SubscribeAsync(string, ICollection<MqttTopicFilter>)

public Task SubscribeAsync(string clientId, ICollection<MqttTopicFilter> topicFilters)

Parameters

clientId string

topicFilters ICollection<MqttTopicFilter>

Returns

Task

UnsubscribeAsync(string, ICollection<string>)

public Task UnsubscribeAsync(string clientId, ICollection<string> topicFilters)

Parameters

clientId string

topicFilters ICollection<string>

Returns

Task