MT服务总线的初始化代码如下:
var messageQueueUri = ConfigurationManager.AppSettings["messageQueueUri"];
messageQueueUri = messageQueueUri.Replace("amqp://", "rabbitmq://");
var bus = ServiceBusFactory.New(sbc =>
{
sbc.UseNLog();
sbc.UseRabbitMq();
sbc.ReceiveFrom(messageQueueUri);
});
应用设置设置为:
amqp://user:passw@bunny.cloudamqp.com/user/my_queue"
在 CloudAMQP 的管理站点中创建名为my_queue的队列。
我使用 nuget 的 MT v2.8.0。我试图从我的本地 PC 和 AppHarbor 站点运行它,并且都抛出异常。
当我更改应用程序设置值以将其指向 RabbitMQ 的本地安装(rabbitmq://localhost/my_queue)时,一切正常。
难道我做错了什么?任何建议将不胜感激。
提前致谢。