単純なstreaminsightアプリをセットアップする際に、server.create()が機能し、server.connect()が失敗するという問題が発生しています。何が原因かわかりません。
編集:ここのソースコード:http://pastebin.com/XigdxXLd
私のセットアップ:
- クライアントがデータを送信するプライベートmsmq
- サーバーは入力アダプターを使用してこのmsmqを読み取り、テキストファイルに出力を生成します
上記の設定で、streaminsightサーバーのメモリ内インスタンスを作成すると(を使用server.create("MyInstance")
して、msmq内のすべてのメッセージを消費し、正常に動作します(server.disposeに配置するのが好きなので、アプリが終了するまでに約1分かかります) ()しばらくお待ちください)。
次を使用してserver.connectに切り替えると、次のようになります。
Server.Connect(
new EndpointAddress(@"http://localhost/StreamInsight/MyInstance")
);
msmqのメッセージを1つだけ消費し、アプリは完了しません。プロジェクトは1分後にタイムアウトしapplication.Delete()
ます(アプリケーションはMS.CEP.applicationです)。
誰かが私が間違っている可能性があることを手伝ってくれますか?
また、StreamInsightHost.exe.config
最近ファイルを開こうとしましたが、メモ帳もVisualStudioでもファイルを開くことができませんでした。これが何かに影響を与える可能性があるかどうかはわかりませんが、私はそれをそこに出すと思っていました。