Class ProducerEndpointBuilder<TEndpoint, TBuilder>

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

Inheritance
System.Object
EndpointBuilder<TEndpoint, TBuilder>
ProducerEndpointBuilder<TEndpoint, TBuilder>
KafkaProducerEndpointBuilder
MqttProducerEndpointBuilder
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 ProducerEndpointBuilder<TEndpoint, TBuilder> : EndpointBuilder<TEndpoint, TBuilder>, IProducerEndpointBuilder<TBuilder>, IEndpointBuilder<TBuilder> where TEndpoint : ProducerEndpoint where TBuilder : IProducerEndpointBuilder<TBuilder>
Type Parameters
Name Description
TEndpoint

The type of the endpoint being built.
TBuilder

The actual builder type.

Constructors

| Improve this doc View source

ProducerEndpointBuilder(Type, IEndpointsConfigurationBuilder)

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

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

The type of the message being produced.
IEndpointsConfigurationBuilder endpointsConfigurationBuilder

The optional reference to the IEndpointsConfigurationBuilder that instantiated the builder.

Methods

| Improve this doc View source

AddHeader(String, Object)

Declaration
public TBuilder AddHeader(string name, object value)
Parameters
Type Name Description
System.String name
System.Object value
Returns
Type Description
TBuilder
| Improve this doc View source

AddHeader<TMessage>(String, Func<IOutboundEnvelope<TMessage>, Object>)

Declaration
public TBuilder AddHeader<TMessage>(string name, Func<IOutboundEnvelope<TMessage>, object> valueProvider)

    where TMessage : class
Parameters
Type Name Description
System.String name
System.Func<IOutboundEnvelope<TMessage>, System.Object> valueProvider
Returns
Type Description
TBuilder
Type Parameters
Name Description
TMessage
| Improve this doc View source

AddHeader<TMessage>(String, Object)

Declaration
public TBuilder AddHeader<TMessage>(string name, object value)

    where TMessage : class
Parameters
Type Name Description
System.String name
System.Object value
Returns
Type Description
TBuilder
Type Parameters
Name Description
TMessage
| 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

EnableChunking(Int32, Boolean)

Declaration
public TBuilder EnableChunking(int chunkSize, bool alwaysAddHeaders = true)
Parameters
Type Name Description
System.Int32 chunkSize
System.Boolean alwaysAddHeaders
Returns
Type Description
TBuilder
| Improve this doc View source

Encrypt(EncryptionSettings)

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

ProduceDirectly()

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

ProduceToOutbox()

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

SerializeUsing(IMessageSerializer)

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

UseStrategy(IProduceStrategy)

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

WithMessageId<TMessage>(Func<IOutboundEnvelope<TMessage>, Object>)

Declaration
public TBuilder WithMessageId<TMessage>(Func<IOutboundEnvelope<TMessage>, object> valueProvider)

    where TMessage : class
Parameters
Type Name Description
System.Func<IOutboundEnvelope<TMessage>, System.Object> valueProvider
Returns
Type Description
TBuilder
Type Parameters
Name Description
TMessage

Implements

Extension Methods