IMessageQueue

Count

public int Count { get; }

value = iMessageQueue.Count

Obtém o número atual de mensagens emparelhadas na fila.

IsClosed

public bool IsClosed { get; }

value = iMessageQueue.IsClosed

Obtém um valor indicando se a fila está fechada.

Clear

public void Clear()

iMessageQueue.Clear()

Remove todas as mensagens da fila.

Close

public void Close()

iMessageQueue.Close()

Fecha a fila e impede que novas mensagens sejam colocadas em espera.

DequeueAsync

public ValueTask<Message> DequeueAsync(CancellationToken cancellationToken)

result = iMessageQueue.DequeueAsync(cancellationToken)

Remove e devolve a próxima mensagem da fila assincronicamente.

cancellationToken

Inscrição de cancelamento.

Retorna: A próxima mensagem na fila.

Enqueue

public ValueTask Enqueue(Message message, CancellationToken cancellationToken)

result = iMessageQueue.Enqueue(message, cancellationToken)

Coloca a mensagem especificada na fila.

message

A mensagem para entrar em fila.

cancellationToken

Inscrição de cancelamento.

Open

public void Open()

iMessageQueue.Open()

Abre a fila e permite enquear e dequear operações.

ReadAllAsync

public IAsyncEnumerable<Message> ReadAllAsync(CancellationToken cancellationToken)

result = iMessageQueue.ReadAllAsync(cancellationToken)

Retorna um assync enumerável que produz mensagens da fila.

cancellationToken

Inscrição de cancelamento.

Retorna: Sincronização enumerável de mensagens.