masstransit

2熱

1答えて

RabbitMQでMT3を使用するアプリケーションをAzureサービスバスに変換していますが、MassTransitではRMQと同じようにAzureでキューを設定していません。（here）他の誰かがこの問題を解決したかどうかを知りたいのですが。私はTokenProvider用のMT 3.4とMicrosoft.ServiceBus 3.0を使用しています。このexample）： public

0熱

1答えて

公開中のMassTransit override ConversationId

メッセージの公開中にフィールドでのMassTransitのビルドを無効にするか、設定する方法はありますか？私の特別なケースでは、私の統合テストのメッセージ公開中にConversationIdをnullに設定する必要があります。私は await Bus.Publish<ITestContractMessage>(new {TestName = "Hello World"}); を使用していたメ

0熱

1答えて

MassTransitメッセージの再試行量を取得

私はMasstransit + RabbitMQを使用しています。私の消費者の一人が再試行ポリシーを実装しています。エラーキューにメッセージが入ったら、メッセージの再試行を行う方法はありますか？また、RabbitMqサーバーを使用してメッセージのヘッダー内の関連情報を検索するために名前を付けなかったため、MTカウントの再試行を知りたいと思います。ありがとうございました。

0熱

1答えて

1か月間に1人のサブスクライバがメッセージを取得しない場合、Azure Service Busのキューを自動的に削除する方法はありますか？

私はMassTransitの輸送手段としてAzureサービスバスを使用しています。現在、1人の加入者が月にメッセージを取得しない場合、自動的にキューを削除する必要があります。私はAutoDeleteOnIdleプロパティについて知っていますが、どのユーザもメッセージを取得しない場合にキューを削除する時間を設定できますか？ azureポータルを使用することができますか（すべての名前空間にこれを設定

0熱

1答えて

MassTransitを使用して複数のコンシューマが1つのキューを購読する方法を教えてください。

私はMassTransitのトランスポートとしてAzureのサービスバスを使用していると私は、キューにメッセージ（コマンド）を送信しようとしています：また var sendEndpoint = await busControl.GetSendEndpoint(sericeUri); sendEndpoint.Send<ISimpleRequest>(new SimpleRequest(custo

0熱

1答えて

消費者シャットダウンの場合はどうなるのですか？（MassTransit）

私はMassTransitを使用し、輸送としてAzure Service Busを使用してコンシューマを作成しました。 public async Task Consume(ConsumeContext<ISimpleRequest> context) { try { _log.InfoFormat("Strated working on {0}", context

1熱

1答えて

異なるメッセージタイプで動作するようにコンフィグレーションする方法（MassTransit）

私は、MassTransitとAzure Service Busをトランスポートとして使用しています。私はIAlertを実装したIAlertとIAlertExtを作成しました。私は2つのメッセージ公開しようとしています： busControl.Publish<IAlert>(new Alert(customerId)); busControl.Publish<IAlertExt>(new Al

1熱

1答えて

Azure Service Busのキューライフタイムとは何ですか？

私は、MassTransitとAzure Service Busをトランスポートとして使用してキューを作成しています。私はメッセージの生涯について尋ねていません。誰もこのキューを購読していないなら、キューがいつ削除されるのかを知る必要がありますか？

0熱

1答えて

サブスクライバが接続した後にパブリッシャが送信するメッセージのみを取得します（マストトランジット）

MassTransitとAzure Service Busをトランスポートとして使用するアプリケーションを作成しました。イベントやコマンドのパブリッシュ、送信、取得 - これはすべてうまく動作します。しかし今、私はサブスクライバを作成して、サブスクライバが接続した後にパブリッシャが送信するメッセージを取得したい。どうやってするか？私は接続する前に出版社によって送られたすべてのメッセージを取得したく

0熱

1答えて

SendObserverをコンテキストを一度消費して取得したISendEndpointに接続します。

ISendEndpointでSendObserverを使用して送信メッセージを監視しようとしています。 ConsumeコンテキストからGetSendEndpointを使用し、ConnectSendObserverを使用してオブザーバを追加すると、以前のメッセージから追加された以前のオブザーバがまだ存在することに気付くため、最初のメッセージの送信後にオブザーバが複数回呼び出されます。消費者コンテキ