Show / Hide Table of Contents

    Interface IProducerEndpoint

    Represents a message broker endpoint to produce to (such as a Kafka topic or RabbitMQ queue or exchange).

    Inherited Members
    IEndpoint.Name
    IEndpoint.DisplayName
    IEndpoint.Serializer
    IEndpoint.Encryption
    IEndpoint.FriendlyName
    IEndpoint.MessageValidationMode
    IEndpoint.Validate()
    Namespace: Silverback.Messaging
    Assembly: Silverback.Integration.dll
    Syntax
    public interface IProducerEndpoint : IEndpoint

    Properties

    | Improve this doc View source

    Chunk

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

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

    MessageEnrichers

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

    Declaration
    IReadOnlyCollection<IOutboundMessageEnricher> MessageEnrichers { get; }
    Property Value
    Type Description
    IReadOnlyCollection<IOutboundMessageEnricher>
    | Improve this doc View source

    Strategy

    Gets 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
    IProduceStrategy Strategy { get; }
    Property Value
    Type Description
    IProduceStrategy

    Methods

    | Improve this doc View source

    GetActualName(IOutboundEnvelope, IServiceProvider)

    Gets the actual target endpoint name for the message being produced.

    Declaration
    string? GetActualName(IOutboundEnvelope envelope, IServiceProvider serviceProvider)
    Parameters
    Type Name Description
    IOutboundEnvelope envelope

    The envelope containing the message being produced.

    IServiceProvider serviceProvider

    The IServiceProvider in the current scope.

    Returns
    Type Description
    string

    The actual name of the endpoint to be produced to.

    • Improve this doc
    • View source
    GitHub E-Mail
    ↑ Back to top © 2020 Sergio Aquilini