Class ProducerEndpoint

Inheritance
System.Object
Endpoint
ProducerEndpoint
KafkaProducerEndpoint
MqttProducerEndpoint
RabbitProducerEndpoint
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 ProducerEndpoint : Endpoint, IProducerEndpoint, IEndpoint

Constructors

| Improve this doc View source

ProducerEndpoint(Func<IOutboundEnvelope, IServiceProvider, String>)

Initializes a new instance of the ProducerEndpoint class.

Declaration
protected ProducerEndpoint(Func<IOutboundEnvelope, IServiceProvider, string> nameFunction)
Parameters
Type Name Description
System.Func<IOutboundEnvelope, System.IServiceProvider, System.String> nameFunction

The function returning the topic name for the message being produced. If the function returns null the message will not be produced.
| Improve this doc View source

ProducerEndpoint(Func<IOutboundEnvelope, String>)

Initializes a new instance of the ProducerEndpoint class.

Declaration
protected ProducerEndpoint(Func<IOutboundEnvelope, string> nameFunction)
Parameters
Type Name Description
System.Func<IOutboundEnvelope, System.String> nameFunction

The function returning the topic name for the message being produced. If the function returns null the message will not be produced.
| Improve this doc View source

ProducerEndpoint(String)

Initializes a new instance of the ProducerEndpoint class.

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

The endpoint name.
| Improve this doc View source

ProducerEndpoint(String, Func<IOutboundEnvelope, String[]>)

Initializes a new instance of the ProducerEndpoint class.

Declaration
protected ProducerEndpoint(string nameFormat, Func<IOutboundEnvelope, string[]> argumentsFunction)
Parameters
Type Name Description
System.String nameFormat

The endpoint name format string that will be combined with the arguments returned by the argumentsFunction using a string.Format.
System.Func<IOutboundEnvelope, System.String[]> argumentsFunction

The function returning the arguments to be used to format the string.
| Improve this doc View source

ProducerEndpoint(Type)

Initializes a new instance of the ProducerEndpoint class.

Declaration
protected ProducerEndpoint(Type resolverType)
Parameters
Type Name Description
System.Type resolverType

The type of the IProducerEndpointNameResolver to be used to resolve the actual endpoint name.

Properties

| Improve this doc View source

Chunk

Gets or sets the message chunking settings. This option can be used to split large messages into smaller chunks.

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

MessageEnrichers

Gets or sets the collection of IOutboundMessageEnricher to be used to enrich the outbound message.

Declaration
public ICollection<IOutboundMessageEnricher> MessageEnrichers { get; set; }
Property Value
Type Description
System.Collections.Generic.ICollection<IOutboundMessageEnricher>
| Improve this doc View source

Strategy

Gets or sets the strategy to be used to produce the messages. If no strategy is specified, the messages will be sent to the message broker directly.

Declaration
public IProduceStrategy Strategy { get; set; }
Property Value
Type Description
IProduceStrategy

Methods

| Improve this doc View source

BaseEquals(Endpoint)

Declaration
protected override bool BaseEquals(Endpoint other)
Parameters
Type Name Description
Endpoint other
Returns
Type Description
System.Boolean
Overrides
| Improve this doc View source

GetActualName(IOutboundEnvelope, IServiceProvider)

Declaration
public string GetActualName(IOutboundEnvelope envelope, IServiceProvider serviceProvider)
Parameters
Type Name Description
IOutboundEnvelope envelope
System.IServiceProvider serviceProvider
Returns
Type Description
System.String
| Improve this doc View source

Validate()

Declaration
public override void Validate()
Overrides

Explicit Interface Implementations

| Improve this doc View source

IProducerEndpoint.MessageEnrichers

Declaration
IReadOnlyCollection<IOutboundMessageEnricher> IProducerEndpoint.MessageEnrichers { get; }
Returns
Type Description
System.Collections.Generic.IReadOnlyCollection<IOutboundMessageEnricher>

Implements