Class OutboundQueueProducer

Inheritance
System.Object
Producer
Producer<TransactionalOutboxBroker, IProducerEndpoint>
OutboundQueueProducer
Implements
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.Outbound.Routing
Assembly: Silverback.Integration.dll
Syntax
public class OutboundQueueProducer : Producer<TransactionalOutboxBroker, IProducerEndpoint>, IProducer

Constructors

| Improve this doc View source

OutboundQueueProducer(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

The IBrokerBehaviorsProvider<TBehavior>.
System.IServiceProvider serviceProvider

The System.IServiceProvider to be used to resolve the needed services.
IOutboundLogger<Producer> logger

The IOutboundLogger<TCategoryName>.

Methods

| Improve this doc View source

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

Declaration
protected override IBrokerMessageIdentifier ProduceCore(object message, byte[] messageBytes, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName)
Parameters
Type Name Description
System.Object message
System.Byte[] messageBytes
System.Collections.Generic.IReadOnlyCollection<MessageHeader> headers
System.String actualEndpointName
Returns
Type Description
IBrokerMessageIdentifier
Overrides
| Improve this doc View source

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

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
System.Byte[] messageBytes
System.Collections.Generic.IReadOnlyCollection<MessageHeader> headers
System.String actualEndpointName
System.Action<IBrokerMessageIdentifier> onSuccess
System.Action<System.Exception> onError
Overrides
| Improve this doc View source

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

Declaration
protected override IBrokerMessageIdentifier ProduceCore(object message, Stream messageStream, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName)
Parameters
Type Name Description
System.Object message
System.IO.Stream messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader> headers
System.String actualEndpointName
Returns
Type Description
IBrokerMessageIdentifier
Overrides
| Improve this doc View source

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

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
System.IO.Stream messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader> headers
System.String actualEndpointName
System.Action<IBrokerMessageIdentifier> onSuccess
System.Action<System.Exception> onError
Overrides
| Improve this doc View source

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

Declaration
protected override async Task<IBrokerMessageIdentifier> ProduceCoreAsync(object message, byte[] messageBytes, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName)
Parameters
Type Name Description
System.Object message
System.Byte[] messageBytes
System.Collections.Generic.IReadOnlyCollection<MessageHeader> headers
System.String actualEndpointName
Returns
Type Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>
Overrides
| Improve this doc View source

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

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
System.Byte[] messageBytes
System.Collections.Generic.IReadOnlyCollection<MessageHeader> headers
System.String actualEndpointName
System.Action<IBrokerMessageIdentifier> onSuccess
System.Action<System.Exception> onError
Returns
Type Description
System.Threading.Tasks.Task
Overrides
| Improve this doc View source

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

Declaration
protected override async Task<IBrokerMessageIdentifier> ProduceCoreAsync(object message, Stream messageStream, IReadOnlyCollection<MessageHeader> headers, string actualEndpointName)
Parameters
Type Name Description
System.Object message
System.IO.Stream messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader> headers
System.String actualEndpointName
Returns
Type Description
System.Threading.Tasks.Task<IBrokerMessageIdentifier>
Overrides
| Improve this doc View source

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

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
System.IO.Stream messageStream
System.Collections.Generic.IReadOnlyCollection<MessageHeader> headers
System.String actualEndpointName
System.Action<IBrokerMessageIdentifier> onSuccess
System.Action<System.Exception> onError
Returns
Type Description
System.Threading.Tasks.Task
Overrides

Implements