如何使用Rhino Service Bus为多个订阅者配置发布订阅？

Question

我正在尝试使用 Rhino Service Bus 在 1 个发布者和多个订阅者之间设置发布-订阅。然而，我似乎得到的只是竞争消费者（消息在一个消费者或另一个消费者之间分发，但不会发送给两者）。

我当前的发布者配置如下所示（注意：我正在使用新的 OnewayRhinoServiceBusFacility，因此我不需要在发送者中定义总线元素）我

<facility id="rhino.esb.sender" >
        <messages>
            <add name="My.Messages.Namespace" endpoint="msmq://localhost/my.queue"/>
        </messages>
</facility>

当前的订阅者配置如下所示：

<facility id="rhino.esb.receiver" >
    <bus threadCount="1" numberOfRetries="5" endpoint="msmq://localhost/my.queue" DisableAutoQueueCreation="false" />
    <messages>
        <add name="My.Messages.Namespace" endpoint="msmq://localhost/my.queue" />
    </messages>
</facility>

我有 2 个启动的简单命令行应用程序发布者和订阅者。我只需复制并粘贴订阅者箱即可设置 2 个订阅者。我的消息处理程序如下所示：

public class DummyReceiver : ConsumerOf<MyMessageType>
{
    public void Consume(MyMessageType message)
    {
                    // ......
            }
    }

有什么想法吗？干杯

Answer 1

哎哟！在我的生产者代码中使用发送而不是发布。从另一个示例复制它并忘记更改。

因此，作为参考，我的发布者代码如下：

var container = new WindsorContainer(new XmlInterpreter("RhinoEsbSettings.xml"));
RhinoServiceBusFacility facility = new RhinoServiceBusFacility();
container.Kernel.AddFacility("rhino.esb", facility);

var bus = container.Resolve<IStartableServiceBus>();
bus.Start();

MyMessageType msg = new ...
bus.Publish(msg);

我的消费者启动代码如下：

var container = new WindsorContainer(new XmlInterpreter("RhinoEsbSettings.xml"));
container.Register(Component.For<ConsumerOf<MyMessageType>>().ImplementedBy<DummyReceiver>().LifeStyle.Transient.Named("Consumer"));

RhinoServiceBusFacility facility = new RhinoServiceBusFacility();
container.Kernel.AddFacility("rhino.esb", facility);

var bus = container.Resolve<IStartableServiceBus>();
bus.Start();