Class RabbitConsumerEndpoint

Represents a queue or exchange to consume from.

Inheritance
System.Object
Endpoint
ConsumerEndpoint
RabbitConsumerEndpoint
RabbitExchangeConsumerEndpoint
RabbitQueueConsumerEndpoint
Inherited Members
System.Object.Equals(System.Object)
System.Object.Equals(System.Object, System.Object)
System.Object.GetHashCode()
System.Object.GetType()
System.Object.MemberwiseClone()
System.Object.ReferenceEquals(System.Object, System.Object)
System.Object.ToString()
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
System.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
System.Int32
| 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
System.UInt16
| 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
System.UInt32
| 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)

Declaration
protected override bool BaseEquals(Endpoint other)
Parameters
Type Name Description
Endpoint other
Returns
Type Description
System.Boolean
Overrides
| Improve this doc View source

Validate()

Declaration
public override void Validate()
Overrides

Implements