GetChannelCopy(string key) (defined in Tests.Adapters.TestMqttMediator) | Tests.Adapters.TestMqttMediator | |
IotDash::Services::Mqtt::MqttMediator.GetChannelCopy(TChannelKey key) | IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage > | pure virtual |
GetRetained(string topic) | IotDash.Services.Mqtt.MqttMediator | inline |
HasSubscribersOnTopic(string topic) | Tests.Adapters.TestMqttMediator | virtual |
Keys (defined in Tests.Adapters.TestMqttMediator) | Tests.Adapters.TestMqttMediator | |
MqttSend(string channel, object sender, MqttApplicationMessage msg) (defined in Tests.Adapters.TestMqttMediator) | Tests.Adapters.TestMqttMediator | inlineprotectedvirtual |
Send(string channel, object sender, MqttApplicationMessage msg) | IotDash.Services.Mqtt.MqttMediator | inline |
Send(string topic, object sender, string content) | IotDash.Services.Mqtt.MqttMediator | inline |
AbstractMediator< string, MqttApplicationMessage >.Send(TChannelKey msgChannel, object sender, TMsg msg) | IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage > | pure virtual |
Subscribe(string msgChannel, ITarget< string, MqttApplicationMessage > target, out ISubscription subscription) (defined in Tests.Adapters.TestMqttMediator) | Tests.Adapters.TestMqttMediator | |
IotDash::Services::Mqtt::MqttMediator.Subscribe(TChannelKey msgChannel, ITarget< TChannelKey, TMsg > target, out ISubscription subscription) | IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage > | inlinevirtual |
IotDash::Services::Mqtt::MqttMediator.Subscribe(TChannelKey msgChannel, ITarget< TChannelKey, TMsg > target, SubscriptionGuard guard) | IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage > | inlinevirtual |
SubscribeInternal(string msgChannel, ITarget< string, MqttApplicationMessage > target) (defined in Tests.Adapters.TestMqttMediator) | Tests.Adapters.TestMqttMediator | inlineprotected |
IotDash::Services::Mqtt::MqttMediator.SubscribeInternal(TChannelKey msgChannel, ITarget< TChannelKey, TMsg > target) | IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage > | protectedpure virtual |
TargetCount (defined in Tests.Adapters.TestMqttMediator) | Tests.Adapters.TestMqttMediator | |
TargetCountOnChannel(string key) (defined in Tests.Adapters.TestMqttMediator) | Tests.Adapters.TestMqttMediator | |
IotDash::Services::Mqtt::MqttMediator.TargetCountOnChannel(TChannelKey key) | IotDash.Domain.Mediator.AbstractMediator< string, MqttApplicationMessage > | pure virtual |
TestMqttMediator() (defined in Tests.Adapters.TestMqttMediator) | Tests.Adapters.TestMqttMediator | inline |
TestMqttMediator(Queue<(object sender, MqttApplicationMessage msg)> sentMessages) (defined in Tests.Adapters.TestMqttMediator) | Tests.Adapters.TestMqttMediator | inline |
Unsubscribe(ISubscription< string, MqttApplicationMessage > subscription) (defined in Tests.Adapters.TestMqttMediator) | Tests.Adapters.TestMqttMediator | |