Class LoggerAzureServiceBusExtensions

Namespace

Stratara.Outbox.AzureServiceBus.Diagnostics.Extensions

Assembly

Stratara.Outbox.AzureServiceBus.dll

Source-generated logger extensions used by the Azure Service Bus message-bus implementation.

public static class LoggerAzureServiceBusExtensions

Inheritance

object

LoggerAzureServiceBusExtensions

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Methods

LogBrokerDeliveryLimitBelowBounds(ILogger, string, string, int, int)

Warns that the subscription's own delivery limit is below the framework's bounds; the bounds for that subscription are lowered to fit under it.

[LoggerMessage(EventId = 108111, Level = LogLevel.Warning, Message = "Subscription {Subscription} on topic {Topic} has MaxDeliveryCount {BrokerLimit}, below the {RequiredLimit} the configured retry bounds need; the bounds for this subscription are lowered to fit under it.")]
public static void LogBrokerDeliveryLimitBelowBounds(this ILogger logger, string topic, string subscription, int brokerLimit, int requiredLimit)

Parameters

logger ILogger

The logger.

topic string

The topic.

subscription string

The subscription whose limit is too low.

brokerLimit int

The subscription's MaxDeliveryCount.

requiredLimit int

The count the framework's bounds need.

LogCommittedEventsNotPublished(ILogger, string, Exception)

Logs that a handler committed its events but could not publish them, so the message is acknowledged instead of delivered again: running it twice would record the events twice.

[LoggerMessage(EventId = 108113, Level = LogLevel.Error, Message = "A message from topic {Topic} committed its events but could not publish them; it is acknowledged so it is not run twice. Replay the projections that consume those events.")]
public static void LogCommittedEventsNotPublished(this ILogger logger, string topic, Exception exception)

Parameters

logger ILogger

The logger.

topic string

The topic the message came from.

exception Exception

The save's failure, naming the committed streams.

LogConcurrencyConflictRequeued(ILogger, Guid, string)

Logs that a handler threw ConcurrencyException and the bus is abandoning the message for redelivery.

[LoggerMessage(EventId = 108105, Level = LogLevel.Warning, Message = "Concurrency conflict on stream {StreamId} ({AggregateTypeName}) — abandoning for redelivery")]
public static void LogConcurrencyConflictRequeued(this ILogger logger, Guid streamId, string aggregateTypeName)

Parameters

logger ILogger

The logger.

streamId Guid

The aggregate stream id involved in the conflict.

aggregateTypeName string

The CLR type name of the aggregate.

LogMessageDeadLettered(ILogger, string, string, string, int)

Logs that a message exhausted its redelivery bound and was moved to the subscription's dead-letter queue.

[LoggerMessage(EventId = 108110, Level = LogLevel.Warning, Message = "Message on topic {Topic} dead-lettered for subscription {Subscription} after {DeliveryAttempt} deliveries ({Reason}).")]
public static void LogMessageDeadLettered(this ILogger logger, string topic, string subscription, string reason, int deliveryAttempt)

Parameters

logger ILogger

The logger.

topic string

The topic the message was published to.

subscription string

The subscription that could not take it.

reason string

conflict or failure.

deliveryAttempt int

How many times the message was delivered, counting the last.

LogMessageProcessingFailed(ILogger, string, Exception)

Logs that a message handler threw and the bus is dead-lettering the message.

[LoggerMessage(EventId = 108101, Level = LogLevel.Error, Message = "Error processing message from topic {Topic}")]
public static void LogMessageProcessingFailed(this ILogger logger, string topic, Exception exception)

Parameters

logger ILogger

The logger.

topic string

The Service Bus topic that produced the failing message.

exception Exception

The exception raised by the handler.

LogSubscriptionCleanupFailed(ILogger, string, Exception)

Logs that stopping a subscription's processor failed; the processor is disposed anyway.

[LoggerMessage(EventId = 108107, Level = LogLevel.Warning, Message = "Stopping subscription {Subscription} failed; its processor is disposed anyway.")]
public static void LogSubscriptionCleanupFailed(this ILogger logger, string subscription, Exception exception)

Parameters

logger ILogger

The logger.

subscription string

The subscription being stopped.

exception Exception

The failure.