Struct MessageBrokerQueueMessageProcessedEvent

Namespace

LfrlAnvil.MessageBroker.Server.Events

Assembly

LfrlAnvil.MessageBroker.Server.dll

Represents an event emitted by MessageBrokerQueue after an enqueued message has been processed.

public readonly struct MessageBrokerQueueMessageProcessedEvent

Inherited Members

ValueType.Equals(object)

ValueType.GetHashCode()

object.Equals(object, object)

object.GetType()

object.ReferenceEquals(object, object)

Properties

AckExpiresAt

Moment of pending ACK expiration.

public Timestamp AckExpiresAt { get; }

Property Value

Timestamp

AckId

Id of the pending ACK associated with the message.

public int AckId { get; }

Property Value

int

IsFromDeadLetter

Specifies whether the message is from dead letter.

public bool IsFromDeadLetter { get; }

Property Value

bool

Listener

MessageBrokerChannelPublisherBinding that received the message.

public MessageBrokerChannelListenerBinding Listener { get; }

Property Value

MessageBrokerChannelListenerBinding

MessageId

Unique id of the message.

public ulong MessageId { get; }

Property Value

ulong

MessageRemoved

Specifies whether the data of the message has been removed from the stream's message store due to no longer being referenced.

public bool MessageRemoved { get; }

Property Value

bool

Publisher

IMessageBrokerMessagePublisher that pushed the message.

public IMessageBrokerMessagePublisher Publisher { get; }

Property Value

IMessageBrokerMessagePublisher

Source

Event source.

public MessageBrokerQueueEventSource Source { get; }

Property Value

MessageBrokerQueueEventSource

Methods

ToString()

Returns a string representation of this MessageBrokerQueueMessageProcessedEvent instance.

[Pure]
public override string ToString()

Returns

string

String representation.