Struct MessageBrokerQueueUnackedMessageCollection

Namespace

LfrlAnvil.MessageBroker.Server

Assembly

LfrlAnvil.MessageBroker.Server.dll

Represents a collection of unacked messages stored in a MessageBrokerQueue.

public readonly struct MessageBrokerQueueUnackedMessageCollection

Inherited Members

ValueType.Equals(object)

ValueType.GetHashCode()

ValueType.ToString()

object.Equals(object, object)

object.GetType()

object.ReferenceEquals(object, object)

Properties

Count

Number of stored unacked messages.

public int Count { get; }

Property Value

int

Methods

TryGetByAckId(int)

Attempts to retrieve an unacked message from the store by its ackId.

[Pure]
public MessageBrokerQueueUnackedMessage? TryGetByAckId(int ackId)

Parameters

ackId int

Ack id of the unacked message to retrieve.

Returns

MessageBrokerQueueUnackedMessage?

MessageBrokerQueueUnackedMessage instance associated with the given ackId or null if such a message doesn't exist.

TryGetFirst()

Attempts to retrieve the first unacked message in the queue.

[Pure]
public MessageBrokerQueueUnackedMessage? TryGetFirst()

Returns

MessageBrokerQueueUnackedMessage?

First MessageBrokerQueueUnackedMessage or null if unacked message queue is empty.

TryGetLast()

Attempts to retrieve the last unacked message in the queue.

[Pure]
public MessageBrokerQueueUnackedMessage? TryGetLast()

Returns

MessageBrokerQueueUnackedMessage?

Last MessageBrokerQueueUnackedMessage or null if unacked message queue is empty.