我剛開始編寫pub/sub,我這樣做的方式是我將有一個控制檯應用程序,每運行x個小時並將處理列表作爲隊列消息(每條消息有1個項目)。現在,在酒吧方面,我想聽輸入隊列,一旦有消息到達,我想發佈。來自nservicebus輸入隊列的輪詢
我知道我需要在配置文件中設置輸入隊列名稱和輪詢時間間隔,但是我怎麼做才能讓這個pub實際上保持從輸入隊列中輪詢。
謝謝。
我剛開始編寫pub/sub,我這樣做的方式是我將有一個控制檯應用程序,每運行x個小時並將處理列表作爲隊列消息(每條消息有1個項目)。現在,在酒吧方面,我想聽輸入隊列,一旦有消息到達,我想發佈。來自nservicebus輸入隊列的輪詢
我知道我需要在配置文件中設置輸入隊列名稱和輪詢時間間隔,但是我怎麼做才能讓這個pub實際上保持從輸入隊列中輪詢。
謝謝。
看看這篇文章scheduling recurring tasks in NSB。我認爲你可以使用這種技術,並且不需要2個獨立的進程。
所有你應該要做的就是創建一個實現IHandleMessages<YourMessageTypeHere>
,並在初始化代碼中的一類,使用
IBus bus = Configure.With()
...
.UnicastBus()
.LoadMessageHandlers()
.CreateBus()
.Start();
LoadMessageHandlers()
會掃描當前大會IHandleMessages
實現。每當消息到達時,處理程序將被調用。
(免責聲明:本工程爲NSB 2.1;我還沒有使用2.5還)