Class LoggerOutboxExtensions
- Namespace
- Stratara.Shared.Diagnostics.Extensions
- Assembly
- Stratara.Outbox.RabbitMQ.dll
Source-generated ILogger extension methods for Stratara.Outbox.RabbitMQ.Outbox.OutboxWorker.
Event-IDs are defined in LogEvents.OutboxProcessing.
public static class LoggerOutboxExtensions
- Inheritance
-
LoggerOutboxExtensions
- Inherited Members
Methods
LogOutboxFailed(ILogger, Exception)
Logs that the outbox drain attempt failed unexpectedly; the worker sleeps and retries.
[LoggerMessage(EventId = 106104, Level = LogLevel.Error, Message = "Error while processing outbox.")]
public static void LogOutboxFailed(this ILogger logger, Exception exception)
Parameters
LogOutboxLockNotAcquired(ILogger)
Logs that another worker instance currently holds the outbox distributed lock; this cycle is skipped.
[LoggerMessage(EventId = 106005, Level = LogLevel.Debug, Message = "Outbox distributed lock not acquired; another instance is draining. Skipping cycle.")]
public static void LogOutboxLockNotAcquired(this ILogger logger)
Parameters
loggerILoggerThe logger.
LogOutboxLockReleaseFailed(ILogger, Exception)
Logs that releasing the outbox distributed lock failed; the key will auto-expire on lease end.
[LoggerMessage(EventId = 106107, Level = LogLevel.Warning, Message = "Failed to release outbox distributed lock. The lease will expire automatically.")]
public static void LogOutboxLockReleaseFailed(this ILogger logger, Exception exception)
Parameters
LogOutboxLockUnavailable(ILogger, Exception)
Logs that the distributed-lock store was unavailable when the outbox worker tried to acquire the lock.
[LoggerMessage(EventId = 106106, Level = LogLevel.Warning, Message = "Outbox distributed lock store unavailable. Skipping cycle.")]
public static void LogOutboxLockUnavailable(this ILogger logger, Exception exception)
Parameters
LogOutboxWorkerOperationCanceled(ILogger)
Logs that the outbox worker's processing loop was cancelled by the host.
[LoggerMessage(EventId = 106003, Level = LogLevel.Information, Message = "Outbox-Worker operation canceled.")]
public static void LogOutboxWorkerOperationCanceled(this ILogger logger)
Parameters
loggerILoggerThe logger.
LogOutboxWorkerStarted(ILogger)
Logs that the outbox worker has started.
[LoggerMessage(EventId = 106001, Level = LogLevel.Information, Message = "Starting Outbox-Worker.")]
public static void LogOutboxWorkerStarted(this ILogger logger)
Parameters
loggerILoggerThe logger.
LogOutboxWorkerStopped(ILogger)
Logs that the outbox worker is shutting down.
[LoggerMessage(EventId = 106002, Level = LogLevel.Information, Message = "Stopping Outbox-Worker.")]
public static void LogOutboxWorkerStopped(this ILogger logger)
Parameters
loggerILoggerThe logger.
LogProjectionReplayCoordinationInProcess(ILogger)
Logs, once at start-up, that no shared coordination store is registered and replay coordination is therefore confined to this process.
[LoggerMessage(EventId = 104012, Level = LogLevel.Warning, Message = "No Redis connection is registered, so projection-replay coordination is confined to this process: a replay requested here suppresses publication here only. Call AddCaching() for a replay to span hosts.")]
public static void LogProjectionReplayCoordinationInProcess(this ILogger logger)
Parameters
loggerILoggerThe logger.
LogProjectionReplayRequestSubscriberFailed(ILogger, Exception)
Logs that a subscriber to the in-process replay-request channel failed. The failure does not
reach the caller of RequestReplay and the remaining subscribers are still notified.
[LoggerMessage(EventId = 104013, Level = LogLevel.Warning, Message = "A projection-replay request subscriber failed. The other subscribers were notified.")]
public static void LogProjectionReplayRequestSubscriberFailed(this ILogger logger, Exception exception)