IMessageQueue

Count

public int Count { get; }

value = iMessageQueue.Count

Получает текущее количество сообщений, буферизованных в очереди.

IsClosed

public bool IsClosed { get; }

value = iMessageQueue.IsClosed

Получает значение, указывающее, закрыта ли очередь.

Clear

public void Clear()

iMessageQueue.Clear()

Удаляет все сообщения из очереди.

Close

public void Close()

iMessageQueue.Close()

Закрывает очередь и предотвращает постановку новых сообщений в очередь.

DequeueAsync

public ValueTask<Message> DequeueAsync(CancellationToken cancellationToken)

result = iMessageQueue.DequeueAsync(cancellationToken)

Асинхронно удаляет и возвращает следующее сообщение из очереди.

cancellationToken

Токен отмены.

Возвращает: Следующее сообщение в очереди.

Enqueue

public ValueTask Enqueue(Message message, CancellationToken cancellationToken)

result = iMessageQueue.Enqueue(message, cancellationToken)

Ставит указанное сообщение в очередь.

message

Сообщение для постановки в очередь.

cancellationToken

Токен отмены.

Open

public void Open()

iMessageQueue.Open()

Открывает очередь и разрешает операции постановки и удаления из очереди.

ReadAllAsync

public IAsyncEnumerable<Message> ReadAllAsync(CancellationToken cancellationToken)

result = iMessageQueue.ReadAllAsync(cancellationToken)

Возвращает асинхронное перечисляемое, которое извлекает сообщения из очереди.

cancellationToken

Токен отмены.

Возвращает: Асинхронное перечисление сообщений.