具有Azure存储的NServiceBus 4在TimeoutPersis中获得NullReourceExc0019

Question

我正在尝试将NServiceBus（版本4.6.0.0）与ASP。NET MVC应用程序托管在Windows Azure网站和Azure存储中以实现持久性，但我在TimeoutManager方面遇到问题。

在尝试使用Azure之前，我让我的应用程序使用默认的MSMQ和RavenDB设置与NServiceBus一起工作，然后改为使用Azure存储。然而，通过这种设置，在NServiceBus中启动之后，我立即收到多个NullReferenceException错误。蔚蓝色的TimoutManagerPersister。TryGetLastSuccessfulRead（）。

我尝试使用存储模拟器和部署到Azure的所有内容运行此本地，但两者都有相同的错误。

以下是我如何在我的应用程序中设置NServiceBus：

全球的尽快。反恐精英

public class MvcApplication : System.Web.HttpApplication
{
    public static IBus Bus { get; private set; }

    protected void Application_Start()
    {
        ...

        Configure.ScaleOut(s => s.UseSingleBrokerQueue());
        Feature.Enable<Sagas>();

        IStartableBus startableBus = Configure.With()
            .DefaultBuilder()
            .DefineEndpointName("MyApp.Web")
            .AzureConfigurationSource()
            .UseTransport<AzureStorageQueue>()
            .AzureMessageQueue()
            .AzureSubscriptionStorage()
            .UseAzureTimeoutPersister()
            .AzureSagaPersister()
            .PurgeOnStartup(false)
            .UnicastBus()
            .LoadMessageHandlers()
            .RunHandlersUnderIncomingPrincipal(false)
            .Log4Net(new DebugAppender { Threshold = Level.Warn })
            .RijndaelEncryptionService()
            .CreateBus();

        Configure.Instance.ForInstallationOn<Windows>().Install();
        Bus = startableBus.Start();
    }
}

Web.config

<configSections>
    <section name="MessageForwardingInCaseOfFaultConfig" type="NServiceBus.Config.MessageForwardingInCaseOfFaultConfig, NServiceBus.Core" />
    <section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
    <section name="AuditConfig" type="NServiceBus.Config.AuditConfig, NServiceBus.Core" />
    <section name="AzureProfileConfig" type="NServiceBus.Config.AzureProfileConfig, NServiceBus.Hosting.Azure" />
    <section name="AzureSubscriptionStorageConfig" type="NServiceBus.Config.AzureSubscriptionStorageConfig, NServiceBus.Azure" />
    <section name="AzureSagaPersisterConfig" type="NServiceBus.Config.AzureSagaPersisterConfig, NserviceBus.Azure" />
    <section name="AzureTimeoutPersisterConfig" type="NServiceBus.Config.AzureTimeoutPersisterConfig, NserviceBus.Azure" />
  </configSections>

  <connectionStrings>
    <add name="NServiceBus/Transport" connectionString="DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=mykey" />
  </connectionStrings>

<AzureSagaPersisterConfig ConnectionString="DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=mykey" CreateSchema="true" />
  <AzureTimeoutPersisterConfig ConnectionString="DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=mykey" TimeoutManagerDataTableName="TimeoutManagerData" TimeoutDataTableName="TimeoutData" />
  <AzureSubscriptionStorageConfig ConnectionString="DefaultEndpointsProtocol=https;AccountName=myaccount;AccountKey=mykey" />

这是我得到的例外：

System.NullReferenceException was unhandled by user code
  HResult=-2147467261
  Message=Object reference not set to an instance of an object.
  Source=Microsoft.Data.Services.Client
  StackTrace:
       at System.Data.Services.Client.UriWriter.VisitResourceSetExpression(ResourceSetExpression rse)
       at System.Data.Services.Client.DataServiceALinqExpressionVisitor.Visit(Expression exp)
       at System.Data.Services.Client.UriWriter.Translate(DataServiceContext context, Boolean addTrailingParens, Expression e, Uri& uri, Version& version)
       at System.Data.Services.Client.DataServiceQueryProvider.Translate(Expression e)
       at System.Data.Services.Client.DataServiceQuery`1.Translate()
       at System.Data.Services.Client.DataServiceQuery`1.Execute()
       at System.Data.Services.Client.DataServiceQuery`1.GetEnumerator()
       at System.Linq.Enumerable.FirstOrDefault[TSource](IEnumerable`1 source)
       at NServiceBus.Azure.SafeLinqExtensions.SafeFirstOrDefault[TSource](IEnumerable`1 source) in y:\BuildAgent\work\ba77a0c29cee2af1\src\NServiceBus.Azure\SafeLinqExtensions.cs:line 13
       at NServiceBus.Azure.TimeoutPersister.TryGetLastSuccessfulRead(ServiceContext context, TimeoutManagerDataEntity& lastSuccessfulReadEntity) in
       y:\BuildAgent\work\ba77a0c29cee2af1\src\NServiceBus.Azure\Timeout\TimeoutLogic\TimeoutPersister.cs:line 338
       at NServiceBus.Azure.TimeoutPersister.GetNextChunk(DateTime startSlice, DateTime& nextTimeToRunQuery) in y:\BuildAgent\work\ba77a0c29cee2af1\src\NServiceBus.Azure\Timeout\TimeoutLogic\TimeoutPersister.cs:line 27
       at NServiceBus.Timeout.Hosting.Windows.TimeoutPersisterReceiver.Poll(Object obj) in y:\BuildAgent\work\31f8c64a6e8a2d7c\src\NServiceBus.Core\Timeout\Hosting\Windows\TimeoutPersisterReceiver.cs:line 80
       at System.Threading.Tasks.Task.InnerInvoke()
       at System.Threading.Tasks.Task.Execute()

即使有错误，消息也会被添加到Azure队列中并正在处理，但只持续几分钟，TimeoutManager就会停止处理，消息不会退出队列。

Answer 1

听起来您正在使用的存储sdk有问题，您使用的是哪个版本？