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

object

LoggerOutboxExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

LogDurableBundleRemovalFailed(ILogger, Guid, Exception)

Logs that a bundle stored with its commit was accepted by the bus but its stored copy could not be removed; the outbox drain will publish it again, which at-least-once already allows.

[LoggerMessage(EventId = 106108, Level = LogLevel.Warning, Message = "Bundle {OutboxEntryId} was accepted by the bus but its stored copy could not be removed; the outbox drain will publish it again.")]
public static void LogDurableBundleRemovalFailed(this ILogger logger, Guid outboxEntryId, Exception exception)

Parameters

logger ILogger

The logger.

outboxEntryId Guid

The stored entry that stays in the table.

exception Exception

The exception raised while removing it.

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

logger ILogger

The logger.

exception Exception

The exception raised while draining the outbox.

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

logger ILogger

The 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

logger ILogger

The logger.

exception Exception

The exception raised while releasing the lock.

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

logger ILogger

The logger.

exception Exception

The exception raised by the lock store.

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

logger ILogger

The 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

logger ILogger

The 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

logger ILogger

The 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

logger ILogger

The logger.

LogProjectionReplayRefreshFailed(ILogger, Exception)

Logs, once per failing stretch, that the host could not refresh what it knows of the replay marking from the shared coordination store. The host keeps its last answer until a refresh succeeds again.

[LoggerMessage(EventId = 104015, Level = LogLevel.Warning, Message = "The replay marking could not be refreshed from Redis; the host keeps its last answer until a refresh succeeds.")]
public static void LogProjectionReplayRefreshFailed(this ILogger logger, Exception exception)

Parameters

logger ILogger

The logger.

exception Exception

What the refresh failed with.

LogProjectionReplayRefreshRecovered(ILogger)

Logs that the host refreshed what it knows of the replay marking again after a failing stretch.

[LoggerMessage(EventId = 104016, Level = LogLevel.Information, Message = "The replay marking is refreshed from Redis again.")]
public static void LogProjectionReplayRefreshRecovered(this ILogger logger)

Parameters

logger ILogger

The 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)

Parameters

logger ILogger

The logger.

exception Exception

The exception the subscriber raised.

LogProjectionReplayStateSubscribed(ILogger)

Logs that the host subscribed to the replay marking's announcement channel again after a failing stretch.

[LoggerMessage(EventId = 104018, Level = LogLevel.Information, Message = "The replay marking's announcement channel is subscribed to again.")]
public static void LogProjectionReplayStateSubscribed(this ILogger logger)

Parameters

logger ILogger

The logger.

LogProjectionReplayStateSubscriptionFailed(ILogger, Exception)

Logs, once per failing stretch, that the host could not subscribe to the channel on which a change of the replay marking is announced. The marking is still refreshed on the period, so a change is seen within it rather than at once; the subscription is tried again on every tick.

[LoggerMessage(EventId = 104017, Level = LogLevel.Warning, Message = "The replay marking's announcement channel could not be subscribed to; a change of the marking is seen on the refresh period only until it can.")]
public static void LogProjectionReplayStateSubscriptionFailed(this ILogger logger, Exception exception)

Parameters

logger ILogger

The logger.

exception Exception

What the subscription failed with.