saga

    2

    1答えて

    カフカをイベントソーシングに使用しています。カフカを使用してサガを実装することに興味があります。私はいくつかの研究をしましたが、そのトピックについて何も見つかりませんでした。 Sagasにはたくさんの情報がありますが、私はKafkaを使った実装にいくつかの複雑さが伴うかもしれないと感じています。これを行う方法に関するベストプラクティス? Commanderのパターンhereはビルドしようとしている

    23

    2答えて

    私はアイテムのリストを持つストアを持っています。私のアプリが最初に読み込まれるとき、アイテムに基づいていくつかのメモリ内オブジェクトを作成する場合と同様に、アイテムを逆シリアル化する必要があります。アイテムは私のレビュックスストアに保存され、itemsReducerで処理されます。 私は副作用として、逆シリアル化を処理するためにredux-sagaを使用しようとしています。最初のページロードでは、

    2

    1答えて

    私のMassTransit sagaには、正しくマップされないフィールドが1つしかありません。それはある -私はそれをカップルの方法をマッピングしようとした public virtual IDictionary<string, string> Rows { get { return _rows; } set { _rows = value; } }

    0

    1答えて

    私は単純なIFindSagaを実装しましたが、SQL Persistence Saga Finding Logicの特定のソフトウェアドキュメントで提供されているのと同じ手順を参照して従いました。 「SynchronizedStorageSessionにはGetSagaDataの定義が含まれておらず、SynchronizedStorageSession型の最初の引数を受け入れる拡張メソッドGetS

    2

    1答えて

    私はMassTransit sagaステートマシン(Automatonymous.MassTransitStateMachineから派生した)を持っています。エンドポイント設定prefetchCountを1より大きな値に設定したときにしか現れない問題を回避しようとしています 問題は 'StartupCompletedEvent'が公開されてから、サガ状態がデータベースに保存される前に直ちに処理され

    0

    1答えて

    マップ内でサガを並行して実行する方法を理解するのに数時間を費やしました。 私が見つけたものを試しました:yield result.map(item => call(api.endpoint, item)) しかし、何も起こっていないようです。ここで は私がやっていたものです。 export function* syncCanvasesByFolder(<someParams>) { yi

    1

    1答えて

    選択効果をテストするにはどうすればよいですか?私のサガは選択の結果に依存しますが、たびに私はサガからundefinedを取得しています。 test.only('Data saga', t => { const generator = loadData(); console.log(generator.next({foo: 'blah'}).value); conso

    0

    1答えて

    現在のプロジェクトでは、firebase websocketサブスクリプションを扱っています。異なるコンポーネントは、異なるデータにサブスクライブすることができます。すべての項目のリストでListItemのコンポーネントは、SUBSCRIBEアクションをにディスパッチし、UNSUBSCRIBEアクションをディスパッチすることによってサブセッションをcomponentWillUnmountにディスパ

    0

    1答えて

    スケジューラーサービスアドレスを直接指定せずにMassTransitステートマシンsagaでスケジューラーを使用しようとしています。 私はUseMessageSchedulerをバス構成で使用しています。これは私のコンシューマの中からcontext.Scheduleすることができます。 しかし、サガでは機能しません。私は.Scheduleをしようとすると、私はこのエラーを取得する: A reque