Class RabbitProducer

Inheritance
System.Object
Producer
Producer<RabbitBroker, RabbitProducerEndpoint>
RabbitProducer
Implements
System.IDisposable
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.RabbitMQ.dll
Syntax
public sealed class RabbitProducer : Producer<RabbitBroker, RabbitProducerEndpoint>, IProducer, IDisposable

Constructors

| Improve this doc View source

RabbitProducer(RabbitBroker, RabbitProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider, IOutboundLogger<Producer>)

Initializes a new instance of the RabbitProducer class.

Declaration
public RabbitProducer(RabbitBroker broker, RabbitProducerEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IServiceProvider serviceProvider, IOutboundLogger<Producer> logger)
Parameters
Type Name Description
RabbitBroker broker

The IBroker that instantiated this producer.
RabbitProducerEndpoint 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 ISilverbackLogger.

Methods

| Improve this doc View source

Dispose()

Declaration
public void Dispose()
| 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

System.IDisposable