Show / Hide Table of Contents

    Class Producer<TBroker, TEndpoint>

    Produces to an endpoint.

    Inheritance
    object
    Producer
    Producer<TBroker, TEndpoint>
    KafkaProducer
    MqttProducer
    RabbitProducer
    OutboundQueueProducer
    Implements
    IProducer
    Inherited Members
    Producer.Id
    Producer.IsConnecting
    Producer.IsConnected
    Producer.ConnectAsync()
    Producer.DisconnectAsync()
    Producer.Produce(object, IReadOnlyCollection<MessageHeader>)
    Producer.Produce(IOutboundEnvelope)
    Producer.Produce(object, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.Produce(IOutboundEnvelope, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.RawProduce(byte[], IReadOnlyCollection<MessageHeader>)
    Producer.RawProduce(Stream, IReadOnlyCollection<MessageHeader>)
    Producer.RawProduce(string, byte[], IReadOnlyCollection<MessageHeader>)
    Producer.RawProduce(string, Stream, IReadOnlyCollection<MessageHeader>)
    Producer.RawProduce(byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.RawProduce(Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.RawProduce(string, byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.RawProduce(string, Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.ProduceAsync(object, IReadOnlyCollection<MessageHeader>)
    Producer.ProduceAsync(IOutboundEnvelope)
    Producer.ProduceAsync(object, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.ProduceAsync(IOutboundEnvelope, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.RawProduceAsync(byte[], IReadOnlyCollection<MessageHeader>)
    Producer.RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>)
    Producer.RawProduceAsync(string, byte[], IReadOnlyCollection<MessageHeader>)
    Producer.RawProduceAsync(string, Stream, IReadOnlyCollection<MessageHeader>)
    Producer.RawProduceAsync(byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.RawProduceAsync(string, byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.RawProduceAsync(string, Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.ConnectCoreAsync()
    Producer.DisconnectCoreAsync()
    Producer.ProduceCore(object, Stream, IReadOnlyCollection<MessageHeader>, string)
    Producer.ProduceCore(object, byte[], IReadOnlyCollection<MessageHeader>, string)
    Producer.ProduceCore(object, Stream, IReadOnlyCollection<MessageHeader>, string, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.ProduceCore(object, byte[], IReadOnlyCollection<MessageHeader>, string, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.ProduceCoreAsync(object, Stream, IReadOnlyCollection<MessageHeader>, string)
    Producer.ProduceCoreAsync(object, byte[], IReadOnlyCollection<MessageHeader>, string)
    Producer.ProduceCoreAsync(object, Stream, IReadOnlyCollection<MessageHeader>, string, Action<IBrokerMessageIdentifier>, Action<Exception>)
    Producer.ProduceCoreAsync(object, byte[], IReadOnlyCollection<MessageHeader>, string, Action<IBrokerMessageIdentifier>, Action<Exception>)
    object.Equals(object)
    object.Equals(object, object)
    object.GetHashCode()
    object.GetType()
    object.MemberwiseClone()
    object.ReferenceEquals(object, object)
    object.ToString()
    Namespace: Silverback.Messaging.Broker
    Assembly: Silverback.Integration.dll
    Syntax
    public abstract class Producer<TBroker, TEndpoint> : Producer, IProducer where TBroker : IBroker where TEndpoint : IProducerEndpoint
    Type Parameters
    Name Description
    TBroker
    TEndpoint

    Constructors

    | Improve this doc View source

    Producer(TBroker, TEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider, IOutboundLogger<Producer>)

    Initializes a new instance of the Producer<TBroker, TEndpoint> class.

    Declaration
    protected Producer(TBroker broker, TEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IServiceProvider serviceProvider, IOutboundLogger<Producer> logger)
    Parameters
    Type Name Description
    TBroker broker

    The IBroker that instantiated this producer.

    TEndpoint endpoint

    The endpoint to produce to.

    IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider

    The IBrokerBehaviorsProvider<TBehavior>.

    IServiceProvider serviceProvider

    The IServiceProvider to be used to resolve the needed services.

    IOutboundLogger<Producer> logger

    The IOutboundLogger<TCategoryName>.

    Properties

    | Improve this doc View source

    Broker

    Gets the TBroker that owns this producer.

    Declaration
    public TBroker Broker { get; }
    Property Value
    Type Description
    TBroker
    | Improve this doc View source

    Endpoint

    Gets the TEndpoint representing the endpoint that is being produced to.

    Declaration
    public TEndpoint Endpoint { get; }
    Property Value
    Type Description
    TEndpoint

    Implements

    IProducer
    • Improve this doc
    • View source
    In this article
    • Constructors
      • Producer(TBroker, TEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider, IOutboundLogger<Producer>)
    • Properties
      • Broker
      • Endpoint
    • Implements
    GitHub E-Mail
    ↑ Back to top © 2020 Sergio Aquilini