1

我一直在尝试实现以下适配器以将 StreamInsight 与 BizTalk 连接： http ://seroter.wordpress.com/2010/07/09/sending-streaminsight-events-to-biztalk-through-new-web-soaprest-适配器/#comment-11635

最后，他执行以下操作将查询绑定到适配器：

var allQuery = callTypeThreshold.ToQuery(
                     myApp,
                     "Threshold Events",
                     string.Empty,
                     typeof(WebOutputFactory),
                     webAdapterBizTalkConfig,
                     EventShape.Point,
                     StreamEventOrder.FullyOrdered);

现在，如果我没记错的话，这在 StreamInsight 2.1 中不再起作用，我不知道如何做到这一点。有人可以帮我吗？提前致谢！

4

1 回答 1

2

您可以将旧适配器模型与较新的 StreamInsight 2.1 API 一起使用。要将输入适配器用作源，您需要使用Application.DefineStreamable()的重载。

所以你的代码看起来像这样：

var sourceStreamable = Application.DefineStreamable<TPayload>(
typeof(WebInputFactory),
webAdapterBizTalkConfig,
EventShape.Point,
AdvanceTimeSettings.IncreasingStartTime);

现在，如果要将输出适配器用作接收器，则需要使用Application.DefineStreamableSink()的重载之一。

因此该代码将如下所示：

var sink = Application.DefineStreamableSink<TPayload>(
typeof(WebOutputFactory),
webAdapterBizTalkConfig,
EventShape.Point,
StreamEventOrder.FullyOrdered);

然后只需使用 Bind() 方法将您的流媒体绑定到接收器，然后使用 Run() 来启动该过程，您就可以开始了。

于 2012-10-13T07:20:42.760 回答