Class Producer

Inheritance

System.Object

Producer

Producer<TBroker, TEndpoint>

Implements

IProducer

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.Broker

Assembly: Silverback.Integration.dll

Syntax

public abstract class Producer : IProducer

Constructors

| Improve this doc View source

Producer(IBroker, IProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider, IOutboundLogger<Producer>)

Initializes a new instance of the Producer class.

Declaration

protected Producer(IBroker broker, IProducerEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IServiceProvider serviceProvider, IOutboundLogger<Producer> logger)

Parameters

Type	Name	Description
IBroker	broker	The IBroker that instantiated this producer.
IProducerEndpoint	endpoint	The endpoint to produce to.
IBrokerBehaviorsProvider<IProducerBehavior>	behaviorsProvider	The IBrokerBehaviorsProvider<TBehavior>.
System.IServiceProvider	serviceProvider	The System.IServiceProvider to be used to resolve the needed services.
IOutboundLogger<Producer>	logger	The IOutboundLogger<TCategoryName>.

Properties

| Improve this doc View source

Broker

Declaration

public IBroker Broker { get; }

Property Value

Type	Description
IBroker

| Improve this doc View source

Endpoint

Declaration

public IProducerEndpoint Endpoint { get; }

Property Value

Type	Description
IProducerEndpoint

| Improve this doc View source

Id

Declaration

public InstanceIdentifier Id { get; }

Property Value

Type	Description
InstanceIdentifier

| Improve this doc View source

IsConnected

Declaration

public bool IsConnected { get; }

Property Value

Type	Description
System.Boolean

| Improve this doc View source

IsConnecting

Declaration

public bool IsConnecting { get; }

Property Value

Type	Description
System.Boolean

Methods

| Improve this doc View source

ConnectAsync()

Declaration

public async Task ConnectAsync()

Returns

Type	Description
System.Threading.Tasks.Task

| Improve this doc View source

ConnectCoreAsync()

Connects to the message broker.

Declaration

protected virtual Task ConnectCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task	A System.Threading.Tasks.Task representing the asynchronous operation.

| Improve this doc View source

DisconnectAsync()

Declaration

public async Task DisconnectAsync()

Returns

Type	Description
System.Threading.Tasks.Task

| Improve this doc View source

DisconnectCoreAsync()

Disconnects from the message broker.

Declaration

protected virtual Task DisconnectCoreAsync()

Returns

Type	Description
System.Threading.Tasks.Task	A System.Threading.Tasks.Task representing the asynchronous operation.

| Improve this doc View source

Produce(IOutboundEnvelope)

Declaration

public IBrokerMessageIdentifier Produce(IOutboundEnvelope envelope)

Parameters

Type	Name	Description
IOutboundEnvelope	envelope

Returns

Type	Description
IBrokerMessageIdentifier

| Improve this doc View source

Produce(IOutboundEnvelope, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public void Produce(IOutboundEnvelope envelope, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
IOutboundEnvelope	envelope
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

| Improve this doc View source

Produce(Object, IReadOnlyCollection<MessageHeader>)

Declaration

public IBrokerMessageIdentifier Produce(object message, IReadOnlyCollection<MessageHeader> headers = null)

Parameters

Type	Name	Description
System.Object	message
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers

Returns

Type	Description
IBrokerMessageIdentifier

| Improve this doc View source

Produce(Object, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public void Produce(object message, IReadOnlyCollection<MessageHeader> headers, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.Object	message
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

| Improve this doc View source

ProduceAsync(IOutboundEnvelope)

Declaration

public async Task<IBrokerMessageIdentifier> ProduceAsync(IOutboundEnvelope envelope)

Parameters

Type	Name	Description
IOutboundEnvelope	envelope

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>

| Improve this doc View source

ProduceAsync(IOutboundEnvelope, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public async Task ProduceAsync(IOutboundEnvelope envelope, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
IOutboundEnvelope	envelope
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

Returns

Type	Description
System.Threading.Tasks.Task

| Improve this doc View source

ProduceAsync(Object, IReadOnlyCollection<MessageHeader>)

Declaration

public Task<IBrokerMessageIdentifier> ProduceAsync(object message, IReadOnlyCollection<MessageHeader> headers = null)

Parameters

Type	Name	Description
System.Object	message
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>

| Improve this doc View source

ProduceAsync(Object, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public Task ProduceAsync(object message, IReadOnlyCollection<MessageHeader> headers, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.Object	message
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

Returns

Type	Description
System.Threading.Tasks.Task

| Improve this doc View source

ProduceCore(Object, Byte[], IReadOnlyCollection<MessageHeader>, String)

Publishes the specified message and returns its identifier.

Declaration

protected abstract IBrokerMessageIdentifier ProduceCore(object message, byte[] messageBytes, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName)

Parameters

Type	Name	Description
System.Object	message	The message to be delivered before serialization. This might be null if RawProduce(Byte[], IReadOnlyCollection<MessageHeader>), RawProduce(Stream, IReadOnlyCollection<MessageHeader>), RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>) or RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>) have been used to produce.
System.Byte[]	messageBytes	The actual serialized message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The message headers.
System.String	actualEndpointName	The actual endpoint to produce to.

Returns

Type	Description
IBrokerMessageIdentifier	The message identifier assigned by the broker (the Kafka offset or similar).

| Improve this doc View source

ProduceCore(Object, Byte[], IReadOnlyCollection<MessageHeader>, String, Action<IBrokerMessageIdentifier>, Action<Exception>)

Publishes the specified message and returns its identifier.

Declaration

protected abstract void ProduceCore(object message, byte[] messageBytes, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.Object	message	The message to be delivered before serialization. This might be null if RawProduce(Byte[], IReadOnlyCollection<MessageHeader>), RawProduce(Stream, IReadOnlyCollection<MessageHeader>), RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>) or RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>) have been used to produce.
System.Byte[]	messageBytes	The actual serialized message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The message headers.
System.String	actualEndpointName	The actual endpoint to produce to.
System.Action<IBrokerMessageIdentifier>	onSuccess	The callback to be invoked when the message is successfully produced.
System.Action<System.Exception>	onError	The callback to be invoked when the produce fails.

Remarks

In this implementation the message is synchronously enqueued but produced asynchronously. The callbacks are called when the message is actually produced (or the produce failed).

| Improve this doc View source

ProduceCore(Object, Stream, IReadOnlyCollection<MessageHeader>, String)

Publishes the specified message and returns its identifier.

Declaration

protected abstract IBrokerMessageIdentifier ProduceCore(object message, Stream messageStream, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName)

Parameters

Type	Name	Description
System.Object	message	The message to be delivered before serialization. This might be null if RawProduce(Byte[], IReadOnlyCollection<MessageHeader>), RawProduce(Stream, IReadOnlyCollection<MessageHeader>), RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>) or RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>) have been used to produce.
System.IO.Stream	messageStream	The actual serialized message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The message headers.
System.String	actualEndpointName	The actual endpoint to produce to.

Returns

Type	Description
IBrokerMessageIdentifier	The message identifier assigned by the broker (the Kafka offset or similar).

| Improve this doc View source

ProduceCore(Object, Stream, IReadOnlyCollection<MessageHeader>, String, Action<IBrokerMessageIdentifier>, Action<Exception>)

Publishes the specified message and returns its identifier.

Declaration

protected abstract void ProduceCore(object message, Stream messageStream, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.Object	message	The message to be delivered before serialization. This might be null if RawProduce(Byte[], IReadOnlyCollection<MessageHeader>), RawProduce(Stream, IReadOnlyCollection<MessageHeader>), RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>) or RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>) have been used to produce.
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The message headers.
System.String	actualEndpointName	The actual endpoint to produce to.
System.Action<IBrokerMessageIdentifier>	onSuccess	The callback to be invoked when the message is successfully produced.
System.Action<System.Exception>	onError	The callback to be invoked when the produce fails.

Remarks

In this implementation the message is synchronously enqueued but produced asynchronously. The callbacks are called when the message is actually produced (or the produce failed).

| Improve this doc View source

ProduceCoreAsync(Object, Byte[], IReadOnlyCollection<MessageHeader>, String)

Publishes the specified message and returns its identifier.

Declaration

protected abstract Task<IBrokerMessageIdentifier> ProduceCoreAsync(object message, byte[] messageBytes, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName)

Parameters

Type	Name	Description
System.Object	message	The message to be delivered before serialization. This might be null if RawProduce(Byte[], IReadOnlyCollection<MessageHeader>), RawProduce(Stream, IReadOnlyCollection<MessageHeader>), RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>) or RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>) have been used to produce.
System.Byte[]	messageBytes	The actual serialized message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The message headers.
System.String	actualEndpointName	The actual endpoint to produce to.

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>	A System.Threading.Tasks.Task<TResult> representing the asynchronous operation. The task result contains the message identifier assigned by the broker (the Kafka offset or similar).

| Improve this doc View source

ProduceCoreAsync(Object, Byte[], IReadOnlyCollection<MessageHeader>, String, Action<IBrokerMessageIdentifier>, Action<Exception>)

Publishes the specified message and returns its identifier.

Declaration

protected abstract Task ProduceCoreAsync(object message, byte[] messageBytes, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.Object	message	The message to be delivered before serialization. This might be null if RawProduce(Byte[], IReadOnlyCollection<MessageHeader>), RawProduce(Stream, IReadOnlyCollection<MessageHeader>), RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>) or RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>) have been used to produce.
System.Byte[]	messageBytes	The actual serialized message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The message headers.
System.String	actualEndpointName	The actual endpoint to produce to.
System.Action<IBrokerMessageIdentifier>	onSuccess	The callback to be invoked when the message is successfully produced.
System.Action<System.Exception>	onError	The callback to be invoked when the produce fails.

Returns

Type	Description
System.Threading.Tasks.Task	A System.Threading.Tasks.Task representing the asynchronous operation. The System.Threading.Tasks.Task will complete as soon as the message is enqueued.

Remarks

The returned System.Threading.Tasks.Task completes when the message is enqueued while the callbacks are called when the message is actually produced (or the produce failed).

| Improve this doc View source

ProduceCoreAsync(Object, Stream, IReadOnlyCollection<MessageHeader>, String)

Publishes the specified message and returns its identifier.

Declaration

protected abstract Task<IBrokerMessageIdentifier> ProduceCoreAsync(object message, Stream messageStream, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName)

Parameters

Type	Name	Description
System.Object	message	The message to be delivered before serialization. This might be null if RawProduce(Byte[], IReadOnlyCollection<MessageHeader>), RawProduce(Stream, IReadOnlyCollection<MessageHeader>), RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>) or RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>) have been used to produce.
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The message headers.
System.String	actualEndpointName	The actual endpoint to produce to.

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>	A System.Threading.Tasks.Task<TResult> representing the asynchronous operation. The task result contains the message identifier assigned by the broker (the Kafka offset or similar).

| Improve this doc View source

ProduceCoreAsync(Object, Stream, IReadOnlyCollection<MessageHeader>, String, Action<IBrokerMessageIdentifier>, Action<Exception>)

Publishes the specified message and returns its identifier.

Declaration

protected abstract Task ProduceCoreAsync(object message, Stream messageStream, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.Object	message	The message to be delivered before serialization. This might be null if RawProduce(Byte[], IReadOnlyCollection<MessageHeader>), RawProduce(Stream, IReadOnlyCollection<MessageHeader>), RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>) or RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>) have been used to produce.
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The message headers.
System.String	actualEndpointName	The actual endpoint to produce to.
System.Action<IBrokerMessageIdentifier>	onSuccess	The callback to be invoked when the message is successfully produced.
System.Action<System.Exception>	onError	The callback to be invoked when the produce fails.

Returns

Type	Description
System.Threading.Tasks.Task	A System.Threading.Tasks.Task representing the asynchronous operation. The System.Threading.Tasks.Task will complete as soon as the message is enqueued.

Remarks

The returned System.Threading.Tasks.Task completes when the message is enqueued while the callbacks are called when the message is actually produced (or the produce failed).

| Improve this doc View source

RawProduce(Byte[], IReadOnlyCollection<MessageHeader>)

Declaration

public IBrokerMessageIdentifier RawProduce(byte[] messageContent, IReadOnlyCollection<MessageHeader> headers = null)

Parameters

Type	Name	Description
System.Byte[]	messageContent
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers

Returns

Type	Description
IBrokerMessageIdentifier

| Improve this doc View source

RawProduce(Byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public void RawProduce(byte[] messageContent, IReadOnlyCollection<MessageHeader> headers, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.Byte[]	messageContent
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

| Improve this doc View source

RawProduce(Stream, IReadOnlyCollection<MessageHeader>)

Declaration

public IBrokerMessageIdentifier RawProduce(Stream messageStream, IReadOnlyCollection<MessageHeader> headers = null)

Parameters

Type	Name	Description
System.IO.Stream	messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers

Returns

Type	Description
IBrokerMessageIdentifier

| Improve this doc View source

RawProduce(Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public void RawProduce(Stream messageStream, IReadOnlyCollection<MessageHeader> headers, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.IO.Stream	messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

| Improve this doc View source

RawProduce(String, Byte[], IReadOnlyCollection<MessageHeader>)

Declaration

public IBrokerMessageIdentifier RawProduce(string actualEndpointName, byte[] messageContent, IReadOnlyCollection<MessageHeader> headers = null)

Parameters

Type	Name	Description
System.String	actualEndpointName
System.Byte[]	messageContent
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers

Returns

Type	Description
IBrokerMessageIdentifier

| Improve this doc View source

RawProduce(String, Byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public void RawProduce(string actualEndpointName, byte[] messageContent, IReadOnlyCollection<MessageHeader> headers, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.String	actualEndpointName
System.Byte[]	messageContent
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

| Improve this doc View source

RawProduce(String, Stream, IReadOnlyCollection<MessageHeader>)

Declaration

public IBrokerMessageIdentifier RawProduce(string actualEndpointName, Stream messageStream, IReadOnlyCollection<MessageHeader> headers = null)

Parameters

Type	Name	Description
System.String	actualEndpointName
System.IO.Stream	messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers

Returns

Type	Description
IBrokerMessageIdentifier

| Improve this doc View source

RawProduce(String, Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public void RawProduce(string actualEndpointName, Stream messageStream, IReadOnlyCollection<MessageHeader> headers, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.String	actualEndpointName
System.IO.Stream	messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

| Improve this doc View source

RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>)

Declaration

public Task<IBrokerMessageIdentifier> RawProduceAsync(byte[] messageContent, IReadOnlyCollection<MessageHeader> headers = null)

Parameters

Type	Name	Description
System.Byte[]	messageContent
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>

| Improve this doc View source

RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public Task RawProduceAsync(byte[] messageContent, IReadOnlyCollection<MessageHeader> headers, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.Byte[]	messageContent
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

Returns

Type	Description
System.Threading.Tasks.Task

| Improve this doc View source

RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>)

Declaration

public Task<IBrokerMessageIdentifier> RawProduceAsync(Stream messageStream, IReadOnlyCollection<MessageHeader> headers = null)

Parameters

Type	Name	Description
System.IO.Stream	messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>

| Improve this doc View source

RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public Task RawProduceAsync(Stream messageStream, IReadOnlyCollection<MessageHeader> headers, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.IO.Stream	messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

Returns

Type	Description
System.Threading.Tasks.Task

| Improve this doc View source

RawProduceAsync(String, Byte[], IReadOnlyCollection<MessageHeader>)

Declaration

public async Task<IBrokerMessageIdentifier> RawProduceAsync(string actualEndpointName, byte[] messageContent, IReadOnlyCollection<MessageHeader> headers = null)

Parameters

Type	Name	Description
System.String	actualEndpointName
System.Byte[]	messageContent
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>

| Improve this doc View source

RawProduceAsync(String, Byte[], IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public Task RawProduceAsync(string actualEndpointName, byte[] messageContent, IReadOnlyCollection<MessageHeader> headers, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.String	actualEndpointName
System.Byte[]	messageContent
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

Returns

Type	Description
System.Threading.Tasks.Task

| Improve this doc View source

RawProduceAsync(String, Stream, IReadOnlyCollection<MessageHeader>)

Declaration

public async Task<IBrokerMessageIdentifier> RawProduceAsync(string actualEndpointName, Stream messageStream, IReadOnlyCollection<MessageHeader> headers = null)

Parameters

Type	Name	Description
System.String	actualEndpointName
System.IO.Stream	messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>

| Improve this doc View source

RawProduceAsync(String, Stream, IReadOnlyCollection<MessageHeader>, Action<IBrokerMessageIdentifier>, Action<Exception>)

Declaration

public Task RawProduceAsync(string actualEndpointName, Stream messageStream, IReadOnlyCollection<MessageHeader> headers, Action<IBrokerMessageIdentifier> onSuccess, Action<Exception> onError)

Parameters

Type	Name	Description
System.String	actualEndpointName
System.IO.Stream	messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers
System.Action<IBrokerMessageIdentifier>	onSuccess
System.Action<System.Exception>	onError

Returns

Type	Description
System.Threading.Tasks.Task

Implements

IProducer