IMessageQueue

Count

public int Count { get; }

value = iMessageQueue.Count

Consigue el número actual de mensajes en la cola.

IsClosed

public bool IsClosed { get; }

value = iMessageQueue.IsClosed

Obtiene un valor indicando si la cola está cerrada.

Clear

public void Clear()

iMessageQueue.Clear()

Elimina todos los mensajes de la cola.

Close

public void Close()

iMessageQueue.Close()

Cierra la cola y evita que se encuerden nuevos mensajes.

DequeueAsync

public ValueTask<Message> DequeueAsync(CancellationToken cancellationToken)

result = iMessageQueue.DequeueAsync(cancellationToken)

Elimina y devuelve el siguiente mensaje de la cola de forma asincrónica.

cancellationToken

Cancelación token.

Devuelve: El siguiente mensaje en la cola.

Enqueue

public ValueTask Enqueue(Message message, CancellationToken cancellationToken)

result = iMessageQueue.Enqueue(message, cancellationToken)

Encuende el mensaje especificado.

message

El mensaje para encubrir.

cancellationToken

Cancelación token.

Open

public void Open()

iMessageQueue.Open()

Abre la cola y permite operaciones de encuado y descomposición.

ReadAllAsync

public IAsyncEnumerable<Message> ReadAllAsync(CancellationToken cancellationToken)

result = iMessageQueue.ReadAllAsync(cancellationToken)

Devuelve un enumerable asinc que da mensajes de la cola.

cancellationToken

Cancelación token.

Devuelve: Async enumerable of messages.