1

我已按如下方式配置订阅：

<add messages="MyNameSpace.MyMessage, MyAssembly" endpoint="FormatName:DIRECT=HTTP://mydomain/msmq/private$\myqueue.input" />

但是当总线启动并发送订阅时，这就是我得到的：

Exception information: 
    Exception type: HttpException 
    Exception message: An exception occurred while attempting to send Rebus.Messages.SubscriptionMessage to FormatName:DIRECT=HTTP://mydomain/msmq/private$\myqueue.input (context: Rebus.Bus.NoTransaction)
   at System.Web.HttpApplicationFactory.EnsureAppStartCalledForIntegratedMode(HttpContext context, HttpApplication app)
   at System.Web.HttpApplication.RegisterEventSubscriptionsWithIIS(IntPtr appContext, HttpContext context, MethodInfo[] handlers)
   at System.Web.HttpApplication.InitSpecial(HttpApplicationState state, MethodInfo[] handlers, IntPtr appContext, HttpContext context)
   at System.Web.HttpApplicationFactory.GetSpecialApplicationInstance(IntPtr appContext, HttpContext context)
   at System.Web.Hosting.PipelineRuntime.InitializeApplication(IntPtr appContext)

An exception occurred while attempting to send Rebus.Messages.SubscriptionMessage to FormatName:DIRECT=HTTP://mydomain/msmq/private$\myqueue.input (context: Rebus.Bus.NoTransaction)
   at Rebus.Bus.RebusBus.InternalSend(String destination, Message messageToSend)
   at Rebus.Bus.RebusBus.InternalSend(String destination, List`1 messages)
   at RehabPathway.Infrastructure.MessagingConfig.RegisterHandlers(IContainer container)
   at RehabPathway.Infrastructure.RehabPathwayHttpApplication.Application_Start(Object sender, EventArgs e)

An error occurred while attempting to send Rebus.TransportMessageToSend to FormatName:DIRECT=HTTP://mydomain/msmq/private$\myqueue.input
   at Rebus.Transports.Msmq.MsmqMessageQueue.Send(String destinationQueueName, TransportMessageToSend message, ITransactionContext context)
   at Rebus.Bus.RebusBus.InternalSend(String destination, Message messageToSend)

Invalid queue path name.
   at System.Messaging.MessageQueue.ResolveFormatNameFromQueuePath(String queuePath, Boolean throwException)
   at System.Messaging.MessageQueue.get_FormatName()
   at System.Messaging.MessageQueue.SendInternal(Object obj, MessageQueueTransaction internalTransaction, MessageQueueTransactionType transactionType)
   at Rebus.Transports.Msmq.MsmqMessageQueue.Send(String destinationQueueName, TransportMessageToSend message, ITransactionContext context)

我已经确认有问题的两台服务器可以通过 HTTP/HTTPS 在 rebus 之外相互发送消息。

4

1 回答 1

0

对于现有的 MSMQ 传输，Rebus 不支持基于 HTTP/HTTPS 的 MSMQ。

Rebus 将始终使用普通的私有 MSMQ 队列，您可以像这样指定队列名称：

 <add messages="MyNameSpace.MyMessage, MyAssembly" endpoint="myqueue.input" />

将消息映射到本地myqueue.input队列，或

 <add messages="MyNameSpace.MyMessage, MyAssembly" endpoint="myqueue.input@anotherHost" />

将消息映射到myqueue.input机器anotherHost上。

如果 MSMQ 在使用 HTTP/HTTPS 时满足相同的交付保证，我想没有理由不能以某种方式对其进行配置 - 现在不支持它。

于 2014-11-21T23:59:34.113 回答