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, IDisposable
Constructors
| 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. |