シーケンス番号のないAzureサービスバスの遅延メッセージのクリーンアップ

Question

シーケンス番号を失った場合、Azure Service Busで遅延メッセージをリカバリまたは削除する方法はありますか？

シナリオ：メッセージを延期するのにBrokeredMessage.Defer()を使用します。シーケンス番号を記録し、後でそれを使用してメッセージを取得する予定です。しかし何かがうまくいかない場合（バグのあるコードが導入されたとしましょう）、シーケンス番号が正しく記録されていない場合、メッセージが期限切れになるまでサービスバスにメッセージが残るようです。

これは、そのメッセージがキューまたはサブスクリプションの領域を占有し、そのキュー/サブスクリプションを完全に削除するのに足りない方法でその領域を回復する方法が見つからなかったためです。

"紛失した"遅延メッセージを受信または削除する方法はありますか？

Answer 1

キューまたはサブスクリプションからのピッキングメッセージは、遅延メッセージも返します。 遅延メッセージはState = "Deferred"になります。

このようにすると、遅延メッセージのシーケンス番号を取得したあとで、これらのメッセージを処理または削除できます。

あなたはServiceBusエクスプローラでこれを試してみることができます。

Answer 2

失われたシーケンス番号のために孤立した据え置きメッセージを防止することに関しては、保持プロセスを保持するストレージプロセスに、おそらくは別のキューを使用して回復力を構築する必要があります。つまり、メッセージを延期する場合は、別のキューまたはトピックにメッセージを作成して、遅延シーケンス番号またはメッセージ全体（クローン）を保存します。

通常、すべての遅延メッセージを自分自身の「遅延トピック」に移動し、別々に処理します。言い換えれば、私自身のカスタム延期論理です。問題を完全に回避します。あなたのシナリオ（BrokeredMessage.TimeToLive）で自動タイムアウトロジックが動作しない場合、これはあなたのためのより良いルートかもしれません。

この記事はQueue.Receiveの特別な過負荷使用して、部分的にあなたのシナリオを説明するのは良い仕事をしていません：あなたは（:-)弾力の方法で）シーケンス番号を記憶しているので

http://markheath.net/post/defer-processing-azure-service-bus-message

をもう1つの方法は、メッセージ全体（JSON、プロパティバッグなど）を保存し、もう一度（別のキューから）処理したいときに再送信することです。