3

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

我当前的发布者配置如下所示（注意：我使用的是新的 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 个简单的命令行应用程序，它们启动发布者和订阅者。我只是复制并粘贴订阅者 bin 来设置 2 个订阅者。我的消息处理程序如下所示：

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

有任何想法吗？干杯

4

1 回答 1

3

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

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

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();
于 2009-12-01T11:31:21.353 回答