MassTransit ESBのCancellationTokenによるリクエスト/レスポンス通信をキャンセルするにはどうすればよいですか？

Question

私は単純なマストトランジットリクエスト/レスポンスの概念証明を持っています。それは2つのアプリケーションで構成されています.1つはメッセージ送信用で、もう1つはメッセージ消費用です。 アプリを送信メッセージは、次のように進む：

var basicClient=_busControl.CreateRequestClient<IRequest,IResponse>(queueUri, timeout); 
return await basicClient.Request(new Request(json), token); 

Request方法は、第二のオプションのパラメータとしてCancellationTokenをとります。我々はConsumeContextもCancellationTokenフィールドを持って見ることができるように

public async Task Consume(ConsumeContext<IRequest> context) 
{ 
     var outputJson = await _longRunningJob.Execute(context.Message.Input, context.CancellationToken); 
     context.Respond(new Response(outputJson)); 
} 

：

メッセージコンシューマは、次のコードを持っています。

質問は次のとおりです。これらのトークンはどのように使用できますか？

私のメッセージ送信アプリでは、 の返信をお待ちしておりますが、メッセージコンシューマでは_longrunningJobの完了を待ってキャンセルしたいと思います。

1. 私はRequestメソッドにトークンを渡ししようと、私は方法がOperationCancelledExceptionを投げることを期待するが、私はちょうど応答を取得私のCancellationTokenSourceにCancel()を呼びます！
2. 私はすでに取り消されたトークンをこのメソッドに渡そうとしましたが、何も起こりませんでした。
3. その後、私はMasstransitのソースコードを見て、token.ThrowIfCancellationIsRequested（）がどこでも呼び出されていないことを知りました！

私はここで何か間違っていると言いますが、CancellationTokensに対処する別の方法があるのですか、まさにMasstransitのバグですか？

Answer 1

リクエストに渡されるCancellationTokenは、リクエスト自体をキャンセルすることです。リクエストはコンシューマに渡されません。

私たちは、次のアプローチを使用して消費者をキャンセルするために管理：

1. が古い場合は、その後UtcNowにExpiryDateヘッダを比較して、消費者に要求（UtcNow +タイムアウト）
2. に満了日のヘッダを追加します。メソッドを終了する