Skip to content

Instantly share code, notes, and snippets.

@samuelsherrer
Created July 22, 2021 23:34
Show Gist options
  • Save samuelsherrer/5eabf30d737d9b961a481fbbbb5a3627 to your computer and use it in GitHub Desktop.
Save samuelsherrer/5eabf30d737d9b961a481fbbbb5a3627 to your computer and use it in GitHub Desktop.
public static class ServiceBusMessageExtensions
{
public const string RetryCountIdentifier = "RetryAttempt";
public static bool ShouldRetry(this Message message, int maxRetryCount)
{
int resubmitCount = message.GetRetryAttempt();
return resubmitCount < maxRetryCount;
}
public static void IncreaseRetryAttempt(this Message message)
{
int retryCount = message.GetRetryAttempt();
message.UserProperties[RetryCountIdentifier] = retryCount + 1;
}
public static int GetRetryAttempt(this Message message)
{
return message.UserProperties.ContainsKey(RetryCountIdentifier) ? (int)message.UserProperties[RetryCountIdentifier] : 0;
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment