2011-03-10 56 views
0

我想要一個簡單的NServiceBus pub/sub工作。這是我想要做的。 我正在嘗試從msmq讀取消息,並且pub將消息發佈到sub,並且sub會將消息插入到sub的隊列中。 (現在,所有電腦都在同一臺計算機上)。pub/sub nservicebus初學者

我有一個酒吧和一個子(有寫作控制檯應用程序)。我也有一個消息類,在這裏。

[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()放在哪裏?我想讀取它們並將它們放入子隊列中。

謝謝。

回答

0

發佈者將處理將消息放入訂閱者的隊列中。要處理這些消息,您必須在訂戶的類中實現IHandleMessages接口。當該類型的消息出現時,NSB將在該類上執行Handle方法。例如:

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