Class MqttProactiveEmitter

Namespace

Kuestenlogik.Bowire.Protocol.Mqtt.Mock

Assembly

Kuestenlogik.Bowire.Protocol.Mqtt.dll

Proactive emitter for Phase 2f: replays the MQTT publishes captured in a BowireRecording onto an embedded MQTTnet broker on a schedule. No HTTP trigger needed — the scheduler fires as soon as a subscriber is attached (or after the startup-grace timeout, whichever comes first). Subscribers that connect late miss already-fired publishes (retained messages stick around per MQTT semantics).

public sealed class MqttProactiveEmitter : IAsyncDisposable

Inheritance

object

MqttProactiveEmitter

Implements

IAsyncDisposable

Inherited Members

object.GetType()

object.ToString()

object.Equals(object)

object.Equals(object, object)

object.ReferenceEquals(object, object)

object.GetHashCode()

Constructors

MqttProactiveEmitter(MqttServer, BowireRecording, double, ILogger, bool)

public MqttProactiveEmitter(MqttServer broker, BowireRecording recording, double speed, ILogger logger, bool loop = false)

Parameters

broker MqttServer

recording BowireRecording

speed double

logger ILogger

loop bool

Methods

DisposeAsync()

public ValueTask DisposeAsync()

Returns

ValueTask

Start()

Kick off the schedule on a background task.

public void Start()