Interface IProducer

Produces to an endpoint.

Namespace: Silverback.Messaging.Broker

Assembly: Silverback.Integration.dll

Syntax

public interface IProducer

Properties

Broker

Gets the IBroker instance that owns this .

Declaration

IBroker Broker { get; }

Property Value

Type	Description
IBroker

Endpoint

Gets the IProducerEndpoint this instance is connected to.

Declaration

IProducerEndpoint Endpoint { get; }

Property Value

Type	Description
IProducerEndpoint

Id

Gets the InstanceIdentifier uniquely identifying the producer instance.

Declaration

InstanceIdentifier Id { get; }

Property Value

Type	Description
InstanceIdentifier

IsConnected

Gets a value indicating whether this producer is connected to the message broker and ready to produce messages.

Declaration

bool IsConnected { get; }

Property Value

Type	Description
System.Boolean

IsConnecting

Gets a value indicating whether this producer is trying to connect to the message broker.

Declaration

bool IsConnecting { get; }

Property Value

Type	Description
System.Boolean

Methods

ConnectAsync()

Initializes the connection to the message broker (if needed).

Declaration

Task ConnectAsync()

Returns

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

DisconnectAsync()

Disconnects from the message broker (if needed).

Declaration

Task DisconnectAsync()

Returns

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

Produce(IOutboundEnvelope)

Publishes the specified message.

Declaration

IBrokerMessageIdentifier Produce(IOutboundEnvelope envelope)

Parameters

Type	Name	Description
IOutboundEnvelope	envelope	The envelope containing the message to be delivered.

Returns

Type	Description
IBrokerMessageIdentifier	The IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message.

Declaration

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

Parameters

Type	Name	Description
IOutboundEnvelope	envelope	The envelope containing the message to be delivered.
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).

Produce(Object, IReadOnlyCollection<MessageHeader>)

Publishes the specified message.

Declaration

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

Parameters

Type	Name	Description
System.Object	message	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.

Returns

Type	Description
IBrokerMessageIdentifier	The IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message.

Declaration

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

Parameters

Type	Name	Description
System.Object	message	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.
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).

ProduceAsync(IOutboundEnvelope)

Publishes the specified message.

Declaration

Task<IBrokerMessageIdentifier> ProduceAsync(IOutboundEnvelope envelope)

Parameters

Type	Name	Description
IOutboundEnvelope	envelope	The envelope containing the message to be delivered.

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>	A System.Threading.Tasks.Task<TResult> representing the asynchronous operation. The task result contains the IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message.

Declaration

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

Parameters

Type	Name	Description
IOutboundEnvelope	envelope	The envelope containing the message to be delivered.
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).

ProduceAsync(Object, IReadOnlyCollection<MessageHeader>)

Publishes the specified message.

Declaration

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

Parameters

Type	Name	Description
System.Object	message	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>	A System.Threading.Tasks.Task<TResult> representing the asynchronous operation. The task result contains the IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message.

Declaration

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

Parameters

Type	Name	Description
System.Object	message	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.
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).

RawProduce(Byte[], IReadOnlyCollection<MessageHeader>)

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.Byte[]	messageContent	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.

Returns

Type	Description
IBrokerMessageIdentifier	The IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.Byte[]	messageContent	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.
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).

RawProduce(Stream, IReadOnlyCollection<MessageHeader>)

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.

Returns

Type	Description
IBrokerMessageIdentifier	The IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.
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).

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

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.String	actualEndpointName	The actual target endpoint name.
System.Byte[]	messageContent	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.

Returns

Type	Description
IBrokerMessageIdentifier	The IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.String	actualEndpointName	The actual target endpoint name.
System.Byte[]	messageContent	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.
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).

RawProduce(String, Stream, IReadOnlyCollection<MessageHeader>)

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.String	actualEndpointName	The actual target endpoint name.
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.

Returns

Type	Description
IBrokerMessageIdentifier	The IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.String	actualEndpointName	The actual target endpoint name.
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.
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).

RawProduceAsync(Byte[], IReadOnlyCollection<MessageHeader>)

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.Byte[]	messageContent	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>	A System.Threading.Tasks.Task<TResult> representing the asynchronous operation. The task result contains the IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.Byte[]	messageContent	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.
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).

RawProduceAsync(Stream, IReadOnlyCollection<MessageHeader>)

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>	A System.Threading.Tasks.Task<TResult> representing the asynchronous operation. The task result contains the IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.
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).

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

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.String	actualEndpointName	The actual target endpoint name.
System.Byte[]	messageContent	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>	A System.Threading.Tasks.Task<TResult> representing the asynchronous operation. The task result contains the IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.String	actualEndpointName	The actual target endpoint name.
System.Byte[]	messageContent	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.
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).

RawProduceAsync(String, Stream, IReadOnlyCollection<MessageHeader>)

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.String	actualEndpointName	The actual target endpoint name.
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.

Returns

Type	Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>	A System.Threading.Tasks.Task<TResult> representing the asynchronous operation. The task result contains the IBrokerMessageIdentifier of the produced record.

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

Publishes the specified message as-is, without sending it through the behaviors pipeline.

Declaration

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

Parameters

Type	Name	Description
System.String	actualEndpointName	The actual target endpoint name.
System.IO.Stream	messageStream	The message to be delivered.
System.Collections.Generic.IReadOnlyCollection<MessageHeader>	headers	The optional message headers.
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).