0

我已经设置了一个发布者/订阅者,并希望将收到的消息发送到审核队列。这里我的 app.config 提取

  <MsmqTransportConfig
InputQueue="MyPublisherInputQueue"
ErrorQueue="error"
NumberOfWorkerThreads="1"
MaxRetries="5"
/>

<UnicastBusConfig
DistributorControlAddress=""
DistributorDataAddress=""
ForwardReceivedMessagesTo="AuditQueue">
<MessageEndpointMappings>
</MessageEndpointMappings>
</UnicastBusConfig>

但是我的消息没有被推送到审核队列我的端点配置就是这样,有订阅者和发布者接口参考

public class EndpointConfig : IConfigureThisEndpoint, AsA_Server, AsA_Publisher
{

}

欢迎任何帮助。

4

2 回答 2

1

您是否有消息处理程序在此端点处理消息?您能否验证这些消息处理程序正在处理消息?

我相信 NServiceBus 只会转发它具有用户配置的消息处理程序的消息,而不仅仅是任何通过实现 IMessage 的东西。如果是这样,您会在审核队列中看到很多消息,用于订阅请求和完成响应以及 NServiceBus 内部的其他内容。

于 2011-10-14T22:18:46.903 回答
0

为什么要 AsA_Server 和 AsA_Publisher?AsA_Publisher 包括 AsA_Server 的所有功能。我想说这就是您的审核队列失败的原因。

于 2011-10-14T11:17:50.703 回答