Class MessageBrokerQueueListenerBinding

Namespace

LfrlAnvil.MessageBroker.Server

Assembly

LfrlAnvil.MessageBroker.Server.dll

Represents a message broker queue binding for a listener, which represents pairing between a channel listener binding and a queue.

public sealed class MessageBrokerQueueListenerBinding

Inheritance

object

MessageBrokerQueueListenerBinding

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.ReferenceEquals(object, object)

Properties

AreAcksEnabled

Specifies whether the client is expected to send ACK or negative ACK to the Queue in order to confirm message notification.

public bool AreAcksEnabled { get; }

Property Value

bool

Client

MessageBrokerRemoteClient instance to which this queue binding belongs to.

public MessageBrokerRemoteClient Client { get; }

Property Value

MessageBrokerRemoteClient

DeadLetterCapacityHint

Specifies how many messages intended for this listener can be stored at most by the Queue's dead letter. Actual capacity may be different due to the state of the Queue and other listeners bound to it.

public int DeadLetterCapacityHint { get; }

Property Value

int

FilterExpression

Specifies message filter expression.

public string? FilterExpression { get; }

Property Value

string

IsPrimary

Specifies whether this listener is a primary queue binding for its Owner.

public bool IsPrimary { get; }

Property Value

bool

MaxRedeliveries

Specifies how many times the Queue will attempt to automatically send a message notification redelivery when the client fails to respond with either an ACK or a negative ACK in time (see MinAckTimeout), before giving up.

public int MaxRedeliveries { get; }

Property Value

int

MaxRetries

Specifies how many times the Queue will attempt to automatically send a message notification retry when the client responds with a negative ACK, before giving up.

public int MaxRetries { get; }

Property Value

int

MinAckTimeout

Specifies the minimum amount of time that the Queue will wait for the client to send either an ACK or a negative ACK before attempting a message notification redelivery. Actual ACK timeout may be different due to the state of the Queue and other listeners bound to it.

public Duration MinAckTimeout { get; }

Property Value

Duration

MinDeadLetterRetention

Specifies the minimum retention period for messages intended for this listener stored in the Queue's dead letter. Actual retention period may be different due to the state of the Queue and other listeners bound to it.

public Duration MinDeadLetterRetention { get; }

Property Value

Duration

Owner

MessageBrokerChannelListenerBinding instance linked with this queue binding.

public MessageBrokerChannelListenerBinding Owner { get; }

Property Value

MessageBrokerChannelListenerBinding

PrefetchHint

Specifies how many messages intended for this listener can be sent by the Queue to the client at the same time.

public int PrefetchHint { get; }

Property Value

int

Queue

MessageBrokerQueue instance which processes messages bound to this listener.

public MessageBrokerQueue Queue { get; }

Property Value

MessageBrokerQueue

RetryDelay

Specifies the delay between the Queue successfully processing negative ACK sent by the client and the Queue sending a message notification retry.

public Duration RetryDelay { get; }

Property Value

Duration

State

Current listener's state.

public MessageBrokerQueueListenerBindingState State { get; }

Property Value

MessageBrokerQueueListenerBindingState

Remarks

See MessageBrokerQueueListenerBindingState for more information.

Methods

ToString()

Returns a string representation of this MessageBrokerQueueListenerBinding instance.

[Pure]
public override string ToString()

Returns

string

String representation.