Class MessageTracker

Namespace

Ratatoskr.Testing

Assembly

Ratatoskr.Testing.dll

Singleton service that collects all message activities from the pipeline. Thread-safe and supports push-based waiting via registered waiters.

public class MessageTracker : IMessageActivityObserver

Inheritance

object

MessageTracker

Implements

IMessageActivityObserver

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

Clear()

Clears all recorded activities and waiters. Useful for test cleanup.

GetActivities(string?)

Gets all recorded activities, optionally filtered by trace ID.

OnMessageActivity(MessageActivity)

Called when a message activity occurs at any pipeline stage.

WaitForAsync(Func<MessageActivity, bool>, TimeSpan, CancellationToken)

Waits for a message activity matching the given predicate. Atomically checks existing activities and subscribes for new ones to avoid TOCTOU races.