Class ConsumerEndpoint

Inheritance
System.Object
Endpoint
ConsumerEndpoint
KafkaConsumerEndpoint
MqttConsumerEndpoint
RabbitConsumerEndpoint
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.dll
Syntax
public abstract class ConsumerEndpoint : Endpoint, IConsumerEndpoint, IEndpoint

Constructors

| Improve this doc View source

ConsumerEndpoint(String)

Initializes a new instance of the ConsumerEndpoint class.

Declaration
protected ConsumerEndpoint(string name)
Parameters
Type Name Description
System.String name

The endpoint name.

Properties

| Improve this doc View source

Batch

Gets or sets the batch settings. Can be used to enable and setup batch processing.

Declaration
public BatchSettings Batch { get; set; }
Property Value
Type Description
BatchSettings
| Improve this doc View source

ErrorPolicy

Gets or sets the error policy to be applied when an exception occurs during the processing of the consumed messages.

Declaration
public IErrorPolicy ErrorPolicy { get; set; }
Property Value
Type Description
IErrorPolicy
| Improve this doc View source

ExactlyOnceStrategy

Gets or sets the strategy to be used to guarantee that each message is consumed only once.

Declaration
public IExactlyOnceStrategy ExactlyOnceStrategy { get; set; }
Property Value
Type Description
IExactlyOnceStrategy
| Improve this doc View source

NullMessageHandlingStrategy

Gets or sets a value indicating how to handle the null messages. The default value is Tombstone.

Declaration
public NullMessageHandlingStrategy NullMessageHandlingStrategy { get; set; }
Property Value
Type Description
NullMessageHandlingStrategy
| Improve this doc View source

Sequence

Gets or sets the sequence settings. A sequence is a set of related messages, like the chunks belonging to the same message or the messages in a dataset.

Declaration
public SequenceSettings Sequence { get; set; }
Property Value
Type Description
SequenceSettings
| Improve this doc View source

ThrowIfUnhandled

Gets or sets a value indicating whether an exception must be thrown if no subscriber is handling the received message. The default is true.

Declaration
public bool ThrowIfUnhandled { get; set; }
Property Value
Type Description
System.Boolean

Methods

| Improve this doc View source

GetUniqueConsumerGroupName()

Declaration
public abstract string GetUniqueConsumerGroupName()
Returns
Type Description
System.String
| Improve this doc View source

Validate()

Declaration
public override void Validate()
Overrides

Implements