Class RabbitQueueConsumerEndpoint
Represents a queue to consume from.
Inheritance
System.Object
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 sourceRabbitQueueConsumerEndpoint(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 sourceEquals(RabbitQueueConsumerEndpoint)
Declaration
public bool Equals(RabbitQueueConsumerEndpoint other)
Parameters
Type | Name | Description |
---|---|---|
RabbitQueueConsumerEndpoint | other |
Returns
Type | Description |
---|---|
System.Boolean |
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>