Class RabbitConsumerEndpoint

Represents a queue or exchange to consume from.

Inheritance
object
Endpoint
ConsumerEndpoint
RabbitConsumerEndpoint
RabbitExchangeConsumerEndpoint
RabbitQueueConsumerEndpoint
Inherited Members
Namespace: Silverback.Messaging
Assembly: Silverback.Integration.RabbitMQ.dll
Syntax
public abstract class RabbitConsumerEndpoint : ConsumerEndpoint, IConsumerEndpoint, IEndpoint

Constructors

| Improve this doc View source

RabbitConsumerEndpoint(string)

Initializes a new instance of the RabbitConsumerEndpoint class.

Declaration
protected RabbitConsumerEndpoint(string name)
Parameters
Type Name Description
string name

The name of the queue or exchange.

Properties

| Improve this doc View source

AcknowledgeEach

Gets or sets the number of message to be processed before sending the acknowledgment to the server. The most reliable level is 1 but it reduces throughput.

Declaration
public int AcknowledgeEach { get; set; }
Property Value
Type Description
int
| Improve this doc View source

Connection

Gets or sets the RabbitMQ connection settings.

Declaration
public RabbitConnectionConfig Connection { get; set; }
Property Value
Type Description
RabbitConnectionConfig
| Improve this doc View source

PrefetchCount

Gets or sets the QoS prefetch count parameter for the consumer.

Declaration
public ushort PrefetchCount { get; set; }
Property Value
Type Description
ushort
| Improve this doc View source

PrefetchSize

Gets or sets the QoS prefetch size parameter for the consumer.

Declaration
public uint PrefetchSize { get; set; }
Property Value
Type Description
uint
| Improve this doc View source

Queue

Gets or sets the queue configuration.

Declaration
public RabbitQueueConfig Queue { get; set; }
Property Value
Type Description
RabbitQueueConfig

Methods

| Improve this doc View source

BaseEquals(Endpoint?)

Determines whether the specified Endpoint is equal to the current Endpoint.

Declaration
protected override bool BaseEquals(Endpoint? other)
Parameters
Type Name Description
Endpoint other

The object to compare with the current object.
Returns
Type Description
bool

Returns a value indicating whether the other object is equal to the current object.
Overrides
| Improve this doc View source

Validate()

Validates the endpoint configuration and throws an EndpointConfigurationException if not valid.

Declaration
public override void Validate()
Overrides

Implements