1

StreamInsightを BizTalk に接続するために、次のアダプターを実装しようとしています。 アダプター/#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()のオーバーロードの 1 つを使用する必要があります。

したがって、そのコードは次のようになります。

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

次に、Bind() メソッドに続いて Run() を使用してストリーム可能オブジェクトをシンクにバインドし、プロセスを開始するだけで準備完了です。

于 2012-10-13T07:20:42.760 に答える