Class ConsumerEndpointBuilder<TEndpoint, TBuilder>

The base class for the builders of the types inheriting from ConsumerEndpoint.

Inheritance
System.Object
EndpointBuilder<TEndpoint, TBuilder>
ConsumerEndpointBuilder<TEndpoint, TBuilder>
KafkaConsumerEndpointBuilder
MqttConsumerEndpointBuilder
Implements
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.Configuration
Assembly: Silverback.Integration.dll
Syntax
public abstract class ConsumerEndpointBuilder<TEndpoint, TBuilder> : EndpointBuilder<TEndpoint, TBuilder>, IConsumerEndpointBuilder<TBuilder>, IEndpointBuilder<TBuilder> where TEndpoint : ConsumerEndpoint where TBuilder : IConsumerEndpointBuilder<TBuilder>
Type Parameters
Name Description
TEndpoint

The type of the endpoint being built.
TBuilder

The actual builder type.

Constructors

| Improve this doc View source

ConsumerEndpointBuilder(Type, IEndpointsConfigurationBuilder)

Initializes a new instance of the ConsumerEndpointBuilder<TEndpoint, TBuilder> class.

Declaration
protected ConsumerEndpointBuilder(Type messageType = null, IEndpointsConfigurationBuilder endpointsConfigurationBuilder = null)
Parameters
Type Name Description
System.Type messageType

The type of the message being consumed.
IEndpointsConfigurationBuilder endpointsConfigurationBuilder

The optional reference to the IEndpointsConfigurationBuilder that instantiated the builder.

Methods

| Improve this doc View source

Build()

Declaration
public override TEndpoint Build()
Returns
Type Description
TEndpoint
Overrides
Silverback.Messaging.Configuration.EndpointBuilder<TEndpoint, TBuilder>.Build()
| Improve this doc View source

Decrypt(EncryptionSettings)

Declaration
public TBuilder Decrypt(EncryptionSettings encryptionSettings)
Parameters
Type Name Description
EncryptionSettings encryptionSettings
Returns
Type Description
TBuilder
| Improve this doc View source

DeserializeUsing(IMessageSerializer)

Declaration
public TBuilder DeserializeUsing(IMessageSerializer serializer)
Parameters
Type Name Description
IMessageSerializer serializer
Returns
Type Description
TBuilder
| Improve this doc View source

EnableBatchProcessing(Int32, Nullable<TimeSpan>)

Declaration
public TBuilder EnableBatchProcessing(int batchSize, TimeSpan? maxWaitTime = null)
Parameters
Type Name Description
System.Int32 batchSize
System.Nullable<System.TimeSpan> maxWaitTime
Returns
Type Description
TBuilder
| Improve this doc View source

EnsureExactlyOnce(IExactlyOnceStrategy)

Declaration
public TBuilder EnsureExactlyOnce(IExactlyOnceStrategy strategy)
Parameters
Type Name Description
IExactlyOnceStrategy strategy
Returns
Type Description
TBuilder
| Improve this doc View source

EnsureExactlyOnce(Action<IExactlyOnceStrategyBuilder>)

Declaration
public TBuilder EnsureExactlyOnce(Action<IExactlyOnceStrategyBuilder> strategyBuilderAction)
Parameters
Type Name Description
System.Action<IExactlyOnceStrategyBuilder> strategyBuilderAction
Returns
Type Description
TBuilder
| Improve this doc View source

HandleTombstoneMessages()

Declaration
public TBuilder HandleTombstoneMessages()
Returns
Type Description
TBuilder
| Improve this doc View source

IgnoreUnhandledMessages()

Declaration
public TBuilder IgnoreUnhandledMessages()
Returns
Type Description
TBuilder
| Improve this doc View source

OnError(IErrorPolicy)

Declaration
public TBuilder OnError(IErrorPolicy errorPolicy)
Parameters
Type Name Description
IErrorPolicy errorPolicy
Returns
Type Description
TBuilder
| Improve this doc View source

OnError(Action<IErrorPolicyBuilder>)

Declaration
public TBuilder OnError(Action<IErrorPolicyBuilder> errorPolicyBuilderAction)
Parameters
Type Name Description
System.Action<IErrorPolicyBuilder> errorPolicyBuilderAction
Returns
Type Description
TBuilder
| Improve this doc View source

SkipNullMessages()

Declaration
public TBuilder SkipNullMessages()
Returns
Type Description
TBuilder
| Improve this doc View source

ThrowIfUnhandled()

Declaration
public TBuilder ThrowIfUnhandled()
Returns
Type Description
TBuilder
| Improve this doc View source

UseLegacyNullMessageHandling()

Declaration
public TBuilder UseLegacyNullMessageHandling()
Returns
Type Description
TBuilder
| Improve this doc View source

WithSequenceTimeout(TimeSpan)

Declaration
public TBuilder WithSequenceTimeout(TimeSpan timeout)
Parameters
Type Name Description
System.TimeSpan timeout
Returns
Type Description
TBuilder

Implements

Extension Methods