Class RabbitQueueConsumerEndpoint
Represents a queue to consume from.
Inherited Members
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 |
|---|---|---|
| string | name | The name of the queue. |
Methods
| Improve this doc View sourceEquals(RabbitQueueConsumerEndpoint?)
Indicates whether the current object is equal to another object of the same type.
Declaration
public bool Equals(RabbitQueueConsumerEndpoint? other)Parameters
| Type | Name | Description |
|---|---|---|
| RabbitQueueConsumerEndpoint | other | An object to compare with this object. |
Returns
| Type | Description |
|---|---|
| bool | true if the current object is equal to the |
Equals(object?)
Determines whether the specified object is equal to the current object.
Declaration
public override bool Equals(object? obj)Parameters
| Type | Name | Description |
|---|---|---|
| object | obj | The object to compare with the current object. |
Returns
| Type | Description |
|---|---|
| bool | true if the specified object is equal to the current object; otherwise, false. |
Overrides
| Improve this doc View sourceGetHashCode()
Serves as the default hash function.
Declaration
public override int GetHashCode()Returns
| Type | Description |
|---|---|
| int | A hash code for the current object. |
Overrides
| Improve this doc View sourceGetUniqueConsumerGroupName()
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 |
|---|---|
| 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.