Class OutboxWorkerService

The IHostedService that triggers the outbound queue worker at regular intervals.

Inheritance

object

BackgroundService

DistributedBackgroundService

RecurringDistributedBackgroundService

OutboxWorkerService

Implements

IHostedService

IDisposable

Inherited Members

RecurringDistributedBackgroundService.Pause()

RecurringDistributedBackgroundService.Resume()

RecurringDistributedBackgroundService.ExecuteLockedAsync(CancellationToken)

DistributedBackgroundService.Lock

DistributedBackgroundService.ExecuteAsync(CancellationToken)

BackgroundService.StartAsync(CancellationToken)

BackgroundService.StopAsync(CancellationToken)

BackgroundService.Dispose()

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Silverback.Messaging.Outbound.TransactionalOutbox

Assembly: Silverback.Integration.dll

Syntax

public class OutboxWorkerService : RecurringDistributedBackgroundService, IHostedService, IDisposable

Constructors

OutboxWorkerService(TimeSpan, IOutboxWorker, DistributedLockSettings, IDistributedLockManager, ISilverbackLogger<OutboxWorkerService>)

Initializes a new instance of the OutboxWorkerService class.

Declaration

public OutboxWorkerService(TimeSpan interval, IOutboxWorker outboxWorker, DistributedLockSettings distributedLockSettings, IDistributedLockManager distributedLockManager, ISilverbackLogger<OutboxWorkerService> logger)

Parameters

Type	Name	Description
TimeSpan	interval	The interval between each execution.
IOutboxWorker	outboxWorker	The IOutboxWorker implementation.
DistributedLockSettings	distributedLockSettings	Customizes the lock mechanism settings.
IDistributedLockManager	distributedLockManager	The IDistributedLockManager.
ISilverbackLogger<OutboxWorkerService>	logger	The ISilverbackLogger.

Methods

ExecuteRecurringAsync(CancellationToken)

Calls the IOutboxWorker to process the queue at regular intervals.

Declaration

protected override Task ExecuteRecurringAsync(CancellationToken stoppingToken)

Parameters

Type	Name	Description
CancellationToken	stoppingToken	A CancellationToken to observe while waiting for the task to complete.

Returns

Type	Description
Task	A Task that represents the long running operations.

Overrides

RecurringDistributedBackgroundService.ExecuteRecurringAsync(CancellationToken)

Implements

IHostedService

IDisposable