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

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

Broker

Gets the TBroker that owns this producer.

Declaration

public TBroker Broker { get; }

Property Value

Type	Description
TBroker

Endpoint

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

Declaration

public TEndpoint Endpoint { get; }

Property Value

Type	Description
TEndpoint

Implements

IProducer