Struct MessageBrokerQueueMessageRetry

Namespace

LfrlAnvil.MessageBroker.Server

Assembly

LfrlAnvil.MessageBroker.Server.dll

Represents a snapshot of a scheduled message retry stored by a MessageBrokerQueue.

public readonly struct MessageBrokerQueueMessageRetry

Inherited Members

ValueType.Equals(object)

ValueType.GetHashCode()

object.Equals(object, object)

object.GetType()

object.ReferenceEquals(object, object)

Properties

Listener

MessageBrokerChannelListenerBinding that handles this message.

public MessageBrokerChannelListenerBinding Listener { get; }

Property Value

MessageBrokerChannelListenerBinding

Publisher

IMessageBrokerMessagePublisher that pushed this message.

public IMessageBrokerMessagePublisher Publisher { get; }

Property Value

IMessageBrokerMessagePublisher

Redelivery

Redelivery attempt of this message.

public int Redelivery { get; }

Property Value

int

Retry

Retry attempt of this message.

public int Retry { get; }

Property Value

int

SendAt

Moment in time when this retry will be activated.

public Timestamp SendAt { get; }

Property Value

Timestamp

StoreKey

Stream store key of this message.

public int StoreKey { get; }

Property Value

int

Methods

ToString()

Returns a string representation of this MessageBrokerQueueMessageRetry instance.

[Pure]
public override string ToString()

Returns

string

String representation.

TryGetMessage(bool)

Attempts to retrieve a message from the stream store by the StoreKey.

[Pure]
public MessageBrokerStreamMessage? TryGetMessage(bool includeData = false)

Parameters

includeData bool

Specifies whether to include a copy of binary data. Equal to false by default.

Returns

MessageBrokerStreamMessage?

MessageBrokerStreamMessage instance associated with the StoreKey or null if such a message doesn't exist.