在设置一个简单的 streaminsight 应用程序时,我遇到了 server.create() 工作且 server.connect() 失败的问题。我不确定可能是什么潜在原因。
编辑:这里的源代码:http: //pastebin.com/XigdxXLd
我的设置:
- 客户端发送数据的私有 msmq
- 服务器使用输入适配器读取此 msmq 并将输出生成到文本文件
使用上述设置,如果我创建了一个 streaminsight 服务器的内存实例(使用server.create("MyInstance")
,它会消耗 msmq 中的所有消息并且工作正常(应用程序退出前大约需要一分钟,因为它喜欢坐在 server.dispose () 叫了一会儿)。
如果我使用以下命令切换到 server.connect:
Server.Connect(
new EndpointAddress(@"http://localhost/StreamInsight/MyInstance")
);
它只消耗 msmq 的一条消息,并且应用程序永远不会完成。该项目在一分钟后超时application.Delete()
(其中应用程序是 MS.CEP.application)。
有人可以帮我解决我可能做错的事情吗?
另外,我最近尝试打开该StreamInsightHost.exe.config
文件,但记事本和 Visual Studio 都不允许我打开它。不确定这是否会影响任何事情,但我只是想我会把它放在那里。