2011-03-08 52 views
0

我剛開始編寫pub/sub,我這樣做的方式是我將有一個控制檯應用程序,每運行x個小時並將處理列表作爲隊列消息(每條消息有1個項目)。現在,在酒吧方面,我想聽輸入隊列,一旦有消息到達,我想發佈。來自nservicebus輸入隊列的輪詢

我知道我需要在配置文件中設置輸入隊列名稱和輪詢時間間隔,但是我怎麼做才能讓這個pub實際上保持從輸入隊列中輪詢。

謝謝。

回答

0

所有你應該要做的就是創建一個實現IHandleMessages<YourMessageTypeHere>,並在初始化代碼中的一類,使用

IBus bus = Configure.With() 
        ... 
        .UnicastBus() 
         .LoadMessageHandlers() 
        .CreateBus() 
        .Start(); 

LoadMessageHandlers()會掃描當前大會IHandleMessages實現。每當消息到達時,處理程序將被調用。

(免責聲明:本工程爲NSB 2.1;我還沒有使用2.5還)