IotDash.Services.Mqtt.Implementation.MqttNet_Mediator Class Reference

Inheritance diagram for IotDash.Services.Mqtt.Implementation.MqttNet_Mediator:

Collaboration diagram for IotDash.Services.Mqtt.Implementation.MqttNet_Mediator:

Public Member Functions
	MqttNet_Mediator (HostedMqttService serviceRoot, IServiceProvider provider)
override int	TargetCountOnChannel (string key)
override bool	HasSubscribersOnTopic (string topic)
override IEnumerable< ITarget< string, MqttApplicationMessage > >	GetChannelCopy (string key)
override void	Subscribe (string topic, ITarget< string, MqttApplicationMessage > target, out ISubscription subscription)
override void	Subscribe (string topic, ITarget< string, MqttApplicationMessage > target, SubscriptionGuard guard)
override void	Unsubscribe (ISubscription< string, MqttApplicationMessage > subscription)
Public Member Functions inherited from IotDash.Services.Mqtt.MqttMediator
abstract bool	HasSubscribersOnTopic (string topic)
MqttApplicationMessage?	GetRetained (string topic)
override Task	Send (string channel, object sender, MqttApplicationMessage msg)
Task	Send (string topic, object sender, string content)
Public Member Functions inherited from IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage >
virtual void	Subscribe (TChannelKey msgChannel, ITarget< TChannelKey, TMsg > target, out ISubscription subscription)
virtual void	Subscribe (TChannelKey msgChannel, ITarget< TChannelKey, TMsg > target, SubscriptionGuard guard)
abstract int	TargetCountOnChannel (TChannelKey key)
abstract IEnumerable< ITarget< TChannelKey, TMsg > >	GetChannelCopy (TChannelKey key)
abstract void	Unsubscribe (ISubscription< TChannelKey, TMsg > subscription)
abstract Task	Send (TChannelKey msgChannel, object sender, TMsg msg)

Protected Member Functions
override async Task	MqttSend (string msgChannel, object sender, MqttApplicationMessage msg)
override void	SubscribeInternal (string topic, ITarget< string, MqttApplicationMessage > target)
abstract Task	MqttSend (string channel, object sender, MqttApplicationMessage msg)
Protected Member Functions inherited from IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage >
abstract void	SubscribeInternal (TChannelKey msgChannel, ITarget< TChannelKey, TMsg > target)

Properties
override int	TargetCount [get]
override IEnumerable< string >	Keys [get]
Properties inherited from IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage >
abstract int	TargetCount [get]
abstract IEnumerable< TChannelKey >	Keys [get]

Detailed Description

A component of the HostedMqttService. Specialisation of MqttMediator designed to work with the MQTTnet.Client.MqttClient.

Member Function Documentation

HasSubscribersOnTopic()

override bool IotDash.Services.Mqtt.Implementation.MqttNet_Mediator.HasSubscribersOnTopic ( string  topic )

virtual

Check if there are any subscribers on given topic .

Parameters

topic

The topic to check.

Returns

true if there are any subscribers.

Implements IotDash.Services.Mqtt.MqttMediator.

MqttSend()

override async Task IotDash.Services.Mqtt.Implementation.MqttNet_Mediator.MqttSend ( string  msgChannel, object  sender, MqttApplicationMessage  msg  )

inlineprotectedvirtual

Send or receive a message. If the sender is the associated HostedMqttService, then the message is broadcasted to in-application listeners. Otherwise the sender is from inside the application, so the message is sent to the broker.

Parameters

msgChannel	The MQTT topic.
sender	Sender of the message.
msg	Message to send.

Returns

Implements IotDash.Services.Mqtt.MqttMediator.

Subscribe() [1/2]

override void IotDash.Services.Mqtt.Implementation.MqttNet_Mediator.Subscribe ( string  topic, ITarget< string, MqttApplicationMessage >  target, out ISubscription  subscription  )

inline

Subscribe target to all messages on given MQTT topic producing a subscription .

Parameters

topic	The topic to subscribe to.
target	The target of the events.
subscription	Subscription object.

Subscribe() [2/2]

override void IotDash.Services.Mqtt.Implementation.MqttNet_Mediator.Subscribe ( string  topic, ITarget< string, MqttApplicationMessage >  target, SubscriptionGuard  guard  )

inline

Subscribe target to all messages on given MQTT topic registering the produced subscription under a given guard .

Parameters

topic	The topic to subscribe to.
target	The target of the events.
guard	Subscription guard under which to register produced ISubscription.

Unsubscribe()

override void IotDash.Services.Mqtt.Implementation.MqttNet_Mediator.Unsubscribe ( ISubscription< string, MqttApplicationMessage >  subscription )

inline

Cancel the given subscription .

Parameters

subscription

The subscription to cancel.

---

The documentation for this class was generated from the following file:

• Services/Implementations/Mqtt/MqttNet_Mediator.cs