Class TransactionalOutboxBroker

An IBroker implementation that is used by the OutboxProduceStrategy to write into the outbox.

Inheritance
System.Object
Broker<IProducerEndpoint, IConsumerEndpoint>
TransactionalOutboxBroker
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.Outbound.TransactionalOutbox
Assembly: Silverback.Integration.dll
Syntax
public class TransactionalOutboxBroker : Broker<IProducerEndpoint, IConsumerEndpoint>, IBroker, IDisposable

Constructors

| Improve this doc View source

TransactionalOutboxBroker(IOutboxWriter, IServiceProvider)

Initializes a new instance of the TransactionalOutboxBroker class.

Declaration
public TransactionalOutboxBroker(IOutboxWriter queueWriter, IServiceProvider serviceProvider)
Parameters
Type Name Description
IOutboxWriter queueWriter

The IOutboxWriter to be used to write to the queue.
System.IServiceProvider serviceProvider

The System.IServiceProvider to be used to resolve the required services.

Methods

| Improve this doc View source

InstantiateConsumer(IConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider)

Declaration
protected override IConsumer InstantiateConsumer(IConsumerEndpoint endpoint, IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider, IServiceProvider serviceProvider)
Parameters
Type Name Description
IConsumerEndpoint endpoint
IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider
System.IServiceProvider serviceProvider
Returns
Type Description
IConsumer
Overrides
Silverback.Messaging.Broker.Broker<Silverback.Messaging.IProducerEndpoint, Silverback.Messaging.IConsumerEndpoint>.InstantiateConsumer(Silverback.Messaging.IConsumerEndpoint, Silverback.Messaging.Broker.Behaviors.IBrokerBehaviorsProvider<Silverback.Messaging.Broker.Behaviors.IConsumerBehavior>, System.IServiceProvider)
| Improve this doc View source

InstantiateProducer(IProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider)

Declaration
protected override IProducer InstantiateProducer(IProducerEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IServiceProvider serviceProvider)
Parameters
Type Name Description
IProducerEndpoint endpoint
IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider
System.IServiceProvider serviceProvider
Returns
Type Description
IProducer
Overrides
Silverback.Messaging.Broker.Broker<Silverback.Messaging.IProducerEndpoint, Silverback.Messaging.IConsumerEndpoint>.InstantiateProducer(Silverback.Messaging.IProducerEndpoint, Silverback.Messaging.Broker.Behaviors.IBrokerBehaviorsProvider<Silverback.Messaging.Broker.Behaviors.IProducerBehavior>, System.IServiceProvider)

Implements

System.IDisposable