Class OutboundQueueProducer
Produces to an endpoint.
Inheritance
Implements
Inherited Members
Namespace: Silverback.Messaging.Outbound.Routing
Assembly: Silverback.Integration.dll
Syntax
public class OutboundQueueProducer : Producer<TransactionalOutboxBroker, IProducerEndpoint>, IProducer
Constructors
| Improve this doc View sourceOutboundQueueProducer(IOutboxWriter, TransactionalOutboxBroker, IProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider, IOutboundLogger<Producer>)
Initializes a new instance of the OutboundQueueProducer class.
Declaration
public OutboundQueueProducer(IOutboxWriter queueWriter, TransactionalOutboxBroker broker, IProducerEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IServiceProvider serviceProvider, IOutboundLogger<Producer> logger)
Parameters
Type | Name | Description |
---|---|---|
IOutboxWriter | queueWriter | The IOutboxWriter to be used to write to the queue. |
TransactionalOutboxBroker | broker | The IBroker that instantiated this producer. |
IProducerEndpoint | endpoint | The endpoint to produce to. |
IBrokerBehaviorsProvider<IProducerBehavior> | behaviorsProvider | |
System.IServiceProvider | serviceProvider | The System.IServiceProvider to be used to resolve the needed services. |
IOutboundLogger<Producer> | logger |
Methods
| Improve this doc View sourceProduceCore(Object, Byte[], IReadOnlyCollection<MessageHeader>, String)
Publishes the specified message and returns its identifier.
Declaration
protected override 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). |
Overrides
| Improve this doc View sourceProduceCore(Object, Byte[], IReadOnlyCollection<MessageHeader>, String, Action<IBrokerMessageIdentifier>, Action<Exception>)
Publishes the specified message and returns its identifier.
Declaration
protected override 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. |
Overrides
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).
ProduceCore(Object, Stream, IReadOnlyCollection<MessageHeader>, String)
Publishes the specified message and returns its identifier.
Declaration
protected override 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). |
Overrides
| Improve this doc View sourceProduceCore(Object, Stream, IReadOnlyCollection<MessageHeader>, String, Action<IBrokerMessageIdentifier>, Action<Exception>)
Publishes the specified message and returns its identifier.
Declaration
protected override 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. |
Overrides
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).
ProduceCoreAsync(Object, Byte[], IReadOnlyCollection<MessageHeader>, String)
Publishes the specified message and returns its identifier.
Declaration
protected override async 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). |
Overrides
| Improve this doc View sourceProduceCoreAsync(Object, Byte[], IReadOnlyCollection<MessageHeader>, String, Action<IBrokerMessageIdentifier>, Action<Exception>)
Publishes the specified message and returns its identifier.
Declaration
protected override async 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. |
Overrides
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).
ProduceCoreAsync(Object, Stream, IReadOnlyCollection<MessageHeader>, String)
Publishes the specified message and returns its identifier.
Declaration
protected override async 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). |
Overrides
| Improve this doc View sourceProduceCoreAsync(Object, Stream, IReadOnlyCollection<MessageHeader>, String, Action<IBrokerMessageIdentifier>, Action<Exception>)
Publishes the specified message and returns its identifier.
Declaration
protected override async 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. |
Overrides
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).