1

我为 azure worker 角色创建了一个新的 NServiceBus。

配置很简单:

NServiceBus.Configure.With(busAssemblies)
                        .Log4Net()
                        .License(Config.Default.NServiceBus_License)
                        .DefineEndpointName(endPointName) 
                        .UnityBuilder(serviceBusDiConfiguration.Container)
                        .AzureConfigurationSource()
                        .AzureSagaPersister()
                        .AzureSubcriptionStorage()
                        .AzureDataBus()
                        .JsonSerializer()
                        .AzureServiceBusMessageQueue()
                        .UnicastBus()
                        .LoadMessageHandlers()
                        .CreateBus()
                        .Start()

除了对.DoNotAutoSubscribe(). 客户端然后使用Bus.Send(message)侦听器的输入队列。

Azure 总线队列报告消息被发送到输入队列并被相应地删除(侦听器正在运行 - 而不是其他情况)。所以是的 - 消息正在从队列中删除。但是我的处理程序没有被触发,并且事件查看器或控制台中没有错误消息(使用开发结构时)。

在此处输入图像描述

唯一的错误,我什至不认为它是相关的,因为在从队列中删除消息时它没有被记录 - 而是在启动时记录它,但错误如下:

[MonAgentHost] Error: MA EVENT: 2013-05-12T22:52:54.925Z
[MonAgentHost] Error:     2
[MonAgentHost] Error:     12084
[MonAgentHost] Error:     6180
[MonAgentHost] Error:     NetTransport
[MonAgentHost] Error:     0
[MonAgentHost] Error:     880e569e-d37b-4262-bdae-dbe5133
[MonAgentHost] Error:     netutils.cpp
[MonAgentHost] Error:     OpenHttpSession
[MonAgentHost] Error:     749
[MonAgentHost] Error:     0
[MonAgentHost] Error:     2f94
[MonAgentHost] Error:     
[MonAgentHost] Error:     WinHttpGetProxyForUrl(http://127.0.0.1) failed ERROR_WINHTTP_AUTODETECTION_FAILED (12180)

这真让我抓狂。我不敢相信有人将 API 设计得如此复杂和不透明——相比之下,它让 Windows Complication Foundation 显得微不足道。请帮我弄清楚出了什么问题,任何提示都表示赞赏,例如。在此文件/文件夹中查找错误日志也可以!

谢谢!

4

1 回答 1

0

我最近遇到了同样的问题,当您在本地定义自己的端点名称和主机(而不是在 Azure 辅助角色中)时,AzureServiceBus 传输出现问题,它不起作用。我最近被 Yves 修复了,但我使用了一种解决方法在 Azure ServiceBus 传输的 app.config 部分中指定完整的端点名称(包括服务 URL)。

  <configSections>
<section name="UnicastBusConfig" type="NServiceBus.Config.UnicastBusConfig, NServiceBus.Core" />
<section name="AzureServiceBusQueueConfig" type="NServiceBus.Config.AzureServiceBusQueueConfig, NServiceBus.Azure" />
<section name="MessageForwardingInCaseOfFaultConfig" type="NServiceBus.Config.MessageForwardingInCaseOfFaultConfig, NServiceBus.Core" />
<section name="Logging" type="NServiceBus.Config.Logging, NServiceBus.Core" />
  </configSections>

 <AzureServiceBusQueueConfig QueueName="myendpoint@mynamespace.servicebus.windows.net" ConnectionString="Endpoint=sb://mynamespace.servicebus.windows.net/;SharedSecretIssuer=owner;SharedSecretValue=mysecret" />
于 2013-10-01T11:26:49.343 回答