Class TransactionalOutboxBroker
An IBroker implementation that is used by the OutboxProduceStrategy to write into the outbox.
Inherited Members
Namespace: Silverback.Messaging.Outbound.TransactionalOutbox
Assembly: Silverback.Integration.dll
Syntax
public class TransactionalOutboxBroker : Broker<IProducerEndpoint, IConsumerEndpoint>, IBroker, IDisposableConstructors
| Improve this doc View sourceTransactionalOutboxBroker(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. |
| IServiceProvider | serviceProvider | The IServiceProvider to be used to resolve the required services. |
Methods
| Improve this doc View sourceInstantiateConsumer(IConsumerEndpoint, IBrokerBehaviorsProvider<IConsumerBehavior>, IServiceProvider)
Returns a new instance of IConsumer to subscribe to the specified endpoint.
Declaration
protected override IConsumer InstantiateConsumer(IConsumerEndpoint endpoint, IBrokerBehaviorsProvider<IConsumerBehavior> behaviorsProvider, IServiceProvider serviceProvider)Parameters
| Type | Name | Description |
|---|---|---|
| IConsumerEndpoint | endpoint | The endpoint. |
| IBrokerBehaviorsProvider<IConsumerBehavior> | behaviorsProvider | |
| IServiceProvider | serviceProvider | The IServiceProvider instance to be used to resolve the needed types or to be forwarded to the consumer. |
Returns
| Type | Description |
|---|---|
| IConsumer | The instantiated IConsumer. |
Overrides
| Improve this doc View sourceInstantiateProducer(IProducerEndpoint, IBrokerBehaviorsProvider<IProducerBehavior>, IServiceProvider)
Returns a new instance of IProducer to publish to the specified endpoint. The returned instance will be cached and reused for the same endpoint.
Declaration
protected override IProducer InstantiateProducer(IProducerEndpoint endpoint, IBrokerBehaviorsProvider<IProducerBehavior> behaviorsProvider, IServiceProvider serviceProvider)Parameters
| Type | Name | Description |
|---|---|---|
| IProducerEndpoint | endpoint | The endpoint. |
| IBrokerBehaviorsProvider<IProducerBehavior> | behaviorsProvider | |
| IServiceProvider | serviceProvider | The IServiceProvider instance to be used to resolve the needed types or to be forwarded to the consumer. |
Returns
| Type | Description |
|---|---|
| IProducer | The instantiated IProducer. |