pub/sub nservicebus初学者

Question

我想要一个简单的NServiceBus pub/sub工作。这是我想要做的。 我正在尝试从msmq读取消息，并且pub将消息发布到sub，并且sub会将消息插入到sub的队列中。 （现在，所有电脑都在同一台计算机上）。

我有一个酒吧和一个子（有写作控制台应用程序）。我也有一个消息类，在这里。

[Serializable] 
public class Message : IEvent 
{ 
    public string name { get; set; } 

} 

public interface IEvent : IMessage 
{ 
    string name { get; set; } 

} 

而且，这是我的酒馆

  IBus bus = NServiceBus.Configure.With() 
      .DefaultBuilder() 
      .XmlSerializer() 
      .MsmqTransport() 
       .IsTransactional(true) 
       .PurgeOnStartup(false) 
      .UnicastBus() 
      .ImpersonateSender(false) 
      .MsmqSubscriptionStorage() 
      .CreateBus(). 
      Start(); 

子看起来相同execpt它有.LoadMessageHandlers（）。

我知道你必须处理这个消息，你把Handle（）放在哪里？我想读取它们并将它们放入子队列中。

谢谢。

Answer 1

发布者将处理将消息放入订阅者的队列中。要处理这些消息，您必须在订户的类中实现IHandleMessages接口。当该类型的消息出现时，NSB将在该类上执行Handle方法。例如：

public class MyMessageHandler : IHandleMessages<Message>; 
{ 
    // do stuff here 
}