在設置一個簡單的streaminsight應用程序時,我遇到了server.create()工作和server.connect()失敗的問題。我不確定可能是什麼原因。server.create()在爲什麼server.connect()不起作用?
編輯:源代碼在這裏:http://pastebin.com/XigdxXLd
我的設置:
- 私人MSMQ,其中客戶端發送數據
- 服務器使用的輸入適配器讀取該MSMQ和產生輸出到一個文本文件
通過上面的設置,如果我創建streaminsight服務器的內存中實例(使用server.create("MyInstance")
,它合併nsumes msmq中的所有消息並且工作正常(應用程序退出前大約需要一分鐘,因爲它喜歡坐在server.dispose()調用一段時間)。
如果我切換到使用的server.connect如下:
Server.Connect(
new EndpointAddress(@"http://localhost/StreamInsight/MyInstance")
);
它只消耗MSMQ的一個消息和應用程序無法完成。在application.Delete()
(其中應用程序是MS.CEP.application)後,項目在一分鐘後超時。
有人可以幫我解決我可能做錯了什麼嗎?
另外,我最近嘗試打開StreamInsightHost.exe.config
文件,但記事本和Visual Studio都不讓我打開它。不知道這是否會影響任何事情,但我只是想我會把它放在那裏。