IMessageQueue

Count

public int Count { get; }

value = iMessageQueue.Count

Die aktuelle Anzahl der Nachrichten wird in der Warteschlange zwischengespeichert.

IsClosed

public bool IsClosed { get; }

value = iMessageQueue.IsClosed

Gibt einen Wert an, der angibt, ob die Warteschlange geschlossen ist.

Clear

public void Clear()

iMessageQueue.Clear()

Entfernt alle Nachrichten aus der Warteschlange.

Close

public void Close()

iMessageQueue.Close()

Schließt die Warteschlange und verhindert, dass neue Nachrichten in die Warteschlange gestellt werden.

DequeueAsync

public ValueTask<Message> DequeueAsync(CancellationToken cancellationToken)

result = iMessageQueue.DequeueAsync(cancellationToken)

Entfernt und gibt die nächste Nachricht aus der Warteschlange asynchron zurück.

cancellationToken

Löschungszeichen.

Rückgabe: Die nächste Nachricht in der Warteschlange.

Enqueue

public ValueTask Enqueue(Message message, CancellationToken cancellationToken)

result = iMessageQueue.Enqueue(message, cancellationToken)

Warteschlange die angegebene Nachricht.

message

Die Nachricht an die Schlange.

cancellationToken

Löschungszeichen.

Open

public void Open()

iMessageQueue.Open()

Öffnet die Warteschlange und ermöglicht Queue- und Dequeue-Operationen.

ReadAllAsync

public IAsyncEnumerable<Message> ReadAllAsync(CancellationToken cancellationToken)

result = iMessageQueue.ReadAllAsync(cancellationToken)

Gibt eine async-enumerable zurück, die Nachrichten aus der Warteschlange liefert.

cancellationToken

Löschungszeichen.

Rückgabe: Async enumerable von Nachrichten.