Class RabbitQueueConsumerEndpoint

Represents a queue to consume from.

Inheritance
System.Object
Endpoint
ConsumerEndpoint
RabbitConsumerEndpoint
RabbitQueueConsumerEndpoint
Inherited Members
System.Object.Equals(System.Object, System.Object)
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 sealed class RabbitQueueConsumerEndpoint : RabbitConsumerEndpoint, IConsumerEndpoint, IEndpoint, IEquatable<RabbitQueueConsumerEndpoint>

Constructors

| Improve this doc View source

RabbitQueueConsumerEndpoint(String)

Initializes a new instance of the RabbitQueueConsumerEndpoint class.

Declaration
public RabbitQueueConsumerEndpoint(string name)
Parameters
Type Name Description
System.String name

The name of the queue.

Methods

| Improve this doc View source

Equals(RabbitQueueConsumerEndpoint)

Declaration
public bool Equals(RabbitQueueConsumerEndpoint other)
Parameters
Type Name Description
RabbitQueueConsumerEndpoint other
Returns
Type Description
System.Boolean
| Improve this doc View source

Equals(Object)

Declaration
public override bool Equals(object obj)
Parameters
Type Name Description
System.Object obj
Returns
Type Description
System.Boolean
Overrides
System.Object.Equals(System.Object)
| Improve this doc View source

GetHashCode()

Declaration
public override int GetHashCode()
Returns
Type Description
System.Int32
Overrides
System.Object.GetHashCode()
| Improve this doc View source

GetUniqueConsumerGroupName()

Gets a unique name for the consumer group (e.g. Kafka's consumer group id). This value (joint with the endpoint name) will be used for example to ensure the exactly-once delivery.

Declaration
public override string GetUniqueConsumerGroupName()
Returns
Type Description
System.String

Returns the unique name for the consumer group.
Overrides
Remarks

It's not enough to use the endpoint name, since the same topic could be consumed by multiple consumer groups within the same process and/or using the same database to store the information needed to ensure the exactly-once delivery.

Implements

System.IEquatable<T>