StorageWriteExceptionRetryPolicy extension for Endjin.Retry

StorageWriteExceptionRetryPolicy.cs

#region Using Directives

using System;
using System.Diagnostics;
using System.Net;

using Endjin.Core.Retry.Policies;
using Endjin.Kpi.Core.Extensions;

using Microsoft.WindowsAzure.Storage;

#endregion

public class StorageWriteExceptionRetryPolicy : IRetryPolicy
{
    public bool CanRetry(Exception ex)
    {
        Trace.TraceError(ex.GetFullExceptionMessage());

        var we = ex as WebException;
        
        if (we != null && we.Status == WebExceptionStatus.ProtocolError)
        {
            return false;
        }

        var se = ex as StorageException;

        if (se != null && se.RequestInformation.HttpStatusCode == (int)HttpStatusCode.Conflict)
        {
            return false;
        }

        return ex is LeaseException;
    }
}