Show / Hide Table of Contents

    Class RabbitQueueConsumerEndpoint

    Represents a queue to consume from.

    Inheritance
    System.Object
    Endpoint
    ConsumerEndpoint
    RabbitConsumerEndpoint
    RabbitQueueConsumerEndpoint
    Implements
    IConsumerEndpoint
    IEndpoint
    System.IEquatable<RabbitQueueConsumerEndpoint>
    Inherited Members
    RabbitConsumerEndpoint.Connection
    RabbitConsumerEndpoint.Queue
    RabbitConsumerEndpoint.AcknowledgeEach
    RabbitConsumerEndpoint.PrefetchSize
    RabbitConsumerEndpoint.PrefetchCount
    RabbitConsumerEndpoint.Validate()
    RabbitConsumerEndpoint.BaseEquals(Endpoint)
    ConsumerEndpoint.ErrorPolicy
    ConsumerEndpoint.ExactlyOnceStrategy
    ConsumerEndpoint.Batch
    ConsumerEndpoint.Sequence
    ConsumerEndpoint.NullMessageHandlingStrategy
    ConsumerEndpoint.ThrowIfUnhandled
    Endpoint.DefaultSerializer
    Endpoint.DisplayName
    Endpoint.Name
    Endpoint.FriendlyName
    Endpoint.Serializer
    Endpoint.Encryption
    Endpoint.MessageValidationMode
    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
    ConsumerEndpoint.GetUniqueConsumerGroupName()
    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

    IConsumerEndpoint
    IEndpoint
    System.IEquatable<T>
    • Improve this doc
    • View source
    GitHub E-Mail
    ↑ Back to top © 2020 Sergio Aquilini