Class StaticProducerEndpointResolver<TEndpoint, TConfiguration>

Statically resolves to the same destination endpoint (e.g. the target topic and partition) for every message being produced.

Inheritance
object
StaticProducerEndpointResolver<TEndpoint, TConfiguration>
KafkaStaticProducerEndpointResolver
MqttStaticProducerEndpointResolver
Inherited Members
Namespace: Silverback.Messaging.Producing.EndpointResolvers
Assembly: Silverback.Integration.dll
Syntax
public abstract class StaticProducerEndpointResolver<TEndpoint, TConfiguration> : IStaticProducerEndpointResolver<TEndpoint>, IStaticProducerEndpointResolver, IProducerEndpointResolver<TEndpoint>, IProducerEndpointResolver, IEquatable<StaticProducerEndpointResolver<TEndpoint, TConfiguration>> where TEndpoint : ProducerEndpoint where TConfiguration : ProducerEndpointConfiguration
Type Parameters
Name Description
TEndpoint

The type of the endpoint being resolved.
TConfiguration

The type of the endpoint configuration.

Constructors

StaticProducerEndpointResolver(string)

Initializes a new instance of the StaticProducerEndpointResolver<TEndpoint, TConfiguration> class.

Declaration
protected StaticProducerEndpointResolver(string rawName)
Parameters
Type Name Description
string rawName

The raw endpoint name that can be used as RawName.

Properties

RawName

Gets the raw endpoint name that can be used as RawName.

Declaration
public string RawName { get; }
Property Value
Type Description
string

Methods

Equals(StaticProducerEndpointResolver<TEndpoint, TConfiguration>?)

Statically resolves to the same destination endpoint (e.g. the target topic and partition) for every message being produced.

Declaration
public virtual bool Equals(StaticProducerEndpointResolver<TEndpoint, TConfiguration>? other)
Parameters
Type Name Description
StaticProducerEndpointResolver<TEndpoint, TConfiguration> other
Returns
Type Description
bool

Equals(object?)

Statically resolves to the same destination endpoint (e.g. the target topic and partition) for every message being produced.

Declaration
public override sealed bool Equals(object? obj)
Parameters
Type Name Description
object obj
Returns
Type Description
bool
Overrides

GetEndpoint(ProducerEndpointConfiguration)

Gets the static destination endpoint.

Declaration
public ProducerEndpoint GetEndpoint(ProducerEndpointConfiguration configuration)
Parameters
Type Name Description
ProducerEndpointConfiguration configuration

The producer endpoint configuration.
Returns
Type Description
ProducerEndpoint

The ProducerEndpoint.

GetEndpoint(IOutboundEnvelope)

Gets the computed actual destination endpoint for the message being produced.

Declaration
public ProducerEndpoint GetEndpoint(IOutboundEnvelope envelope)
Parameters
Type Name Description
IOutboundEnvelope envelope

The envelope containing the message to be produced.
Returns
Type Description
ProducerEndpoint

The ProducerEndpoint for the specified message.

GetEndpoint(TConfiguration)

Gets the static destination endpoint.

Declaration
public TEndpoint GetEndpoint(TConfiguration configuration)
Parameters
Type Name Description
TConfiguration configuration

The producer endpoint configuration.
Returns
Type Description
TEndpoint

The ProducerEndpoint.

GetEndpointCore(TConfiguration)

Gets the static destination endpoint.

Declaration
protected abstract TEndpoint GetEndpointCore(TConfiguration configuration)
Parameters
Type Name Description
TConfiguration configuration

The producer endpoint configuration.
Returns
Type Description
TEndpoint

The ProducerEndpoint.
Remarks

This method will be called once and the result will be cached.

GetHashCode()

Statically resolves to the same destination endpoint (e.g. the target topic and partition) for every message being produced.

Declaration
public override int GetHashCode()
Returns
Type Description
int
Overrides

Operators

operator ==(StaticProducerEndpointResolver<TEndpoint, TConfiguration>?, StaticProducerEndpointResolver<TEndpoint, TConfiguration>?)

Equality operator.

Declaration
public static bool operator ==(StaticProducerEndpointResolver<TEndpoint, TConfiguration>? left, StaticProducerEndpointResolver<TEndpoint, TConfiguration>? right)
Parameters
Type Name Description
StaticProducerEndpointResolver<TEndpoint, TConfiguration> left

Left-hand operand.
StaticProducerEndpointResolver<TEndpoint, TConfiguration> right

Right-hand operand.
Returns
Type Description
bool

operator !=(StaticProducerEndpointResolver<TEndpoint, TConfiguration>?, StaticProducerEndpointResolver<TEndpoint, TConfiguration>?)

Inequality operator.

Declaration
public static bool operator !=(StaticProducerEndpointResolver<TEndpoint, TConfiguration>? left, StaticProducerEndpointResolver<TEndpoint, TConfiguration>? right)
Parameters
Type Name Description
StaticProducerEndpointResolver<TEndpoint, TConfiguration> left

Left-hand operand.
StaticProducerEndpointResolver<TEndpoint, TConfiguration> right

Right-hand operand.
Returns
Type Description
bool

Implements