問題タブ [nservicebus4]

NServiceBusHost.exe に問題があります。

現在、NServiceBusHost.exe を Windows サービスとして実行しており、次のようにタイムアウト例外が発生しています。

Microsoft サービス トレース ビューアの出力:

このタイムアウト例外の発生を回避することを考えています。HTTP ランタイムのタイムアウトを延長する必要があります。

.NET での HTTPRuntime 構成の実行タイムアウト (.NET 4.0 のデフォルトは 1:10 分) が NServiceBusHost.exe に適用されると考えるのが正しいかどうか、誰にもわかりますか?

さらに、NServiceBusHost.exe はトップシェルフ上に構築されていると思います。NServiceBusHost.exe の問題をログに記録するために log4net 構成を適用できるという考えは正しいですか?

前もって感謝します。

現在、新しいシステムを導入中です。私のメッセージの内容が間違っていて、接続しているシステムによって拒否されることがあります (REST サービスを介してデータを転送します)。メッセージがエラー キューに入ったらすぐに編集して、再度キューに入れることができます。しかし、NServiceBus が再送信しようとしている間 (もちろん毎回失敗します)、次回のために修正するためのメッセージが見つからないようです。SLR 中にメッセージが「パーク」されている場所はありますか?

WebSphere mq を使用するように NServiceBus プロジェクトを構成しようとしています。私は他のすべてのウェブを検索してきましたが、最新の例は見つかりませんでした。この投稿によると、WMQ 構成用の API を公開する dll があります。ただし、彼らの例は非常に古い NServiceBus バージョンで動作し、現在の (4.3.1) バージョンとは互換性がありません。いくつかの実際の例を含む唯一のマニュアルはこれであり、PubSub 用であり、単純なクライアント サーバー構成用ではありません。WMQ を使用するように NSB プロジェクトを構成する方法を説明する最新の例を教えてください。

ありがとう！

NServiceBus 3.3.3 システムをバージョン 4 にアップグレードすることを検討しています。

バージョン 4 が DTC なしで動作することを示していると思われる投稿をいくつか読みました。これは本当ですか？

基本的に、これは私がやろうとしていることです：

1. 重複メッセージを処理できるようにハンドラーを変更する
2. NServiceBus のバージョン 4 へのアップグレード
3. データベースで DTC をオフにする

私が読んだことから、これを行うことができ、メッセージを失うことはありません。(私は医療会社で働いており、メッセージを失うことは、患者のデータを失うことを意味します (非常に悪い) .)

他に注意すべき点は、私のシステムがディストリビューターで実行され、ディストリビューターが複数のワーカーに仕事を与えることです。メッセージ スループットは膨大です (DTC を削除するとスループットが向上するのではないかと期待しています)。

補足として、MSMQ から RabbitMQ に切り替えた場合、これは何か違いますか?

次のような Web サービスがあります。

• MSMQ トランスポートを使用します。
• 送信専用の NSB エンドポイントです。
• NSB のメッセージ暗号化を使用します。
• 別のマシンのメッセージ キューに送信します。

メッセージは、ネットワークを介して他のマシンのメッセージ キューに転送されるときに暗号化されますか?

次のコードがあります。

エラー メッセージ: 操作は、トランザクションの状態に対して有効ではありません。

スタックトレース：

* System.Transactions.TransactionState.EnlistVolatile(InternalTransaction tx, IEnlistmentNotification enlistmentNotification, EnlistmentOptions enlistmentOptions, Transaction atomicTransaction) で System.Transactions.Transaction.EnlistVolatile(IEnlistmentNotification enlistmentNotification, EnlistmentOptions enlistmentOptions) でNServiceBus.Unicast.UnicastBus.SendMessage(List1 addresses, String correlationId, MessageIntentEnum messageIntent, Object[] messages) in :line 0 at NServiceBus.Unicast.UnicastBus.SendMessage(Address address, String correlationId, MessageIntentEnum messageIntent, Object[] messages) in :line 0 at NServiceBus.Unicast.UnicastBus.Send(Address address, Object[] messages) in :line 0 at NServiceBus.Unicast.UnicastBus.SendLocal(Object[] messages) in :line 0 at NServiceBus.Unicast.UnicastBus.SendLocal(Object message) in :line 0 at Amira.Merger.WorkerRole.Handlers.ProcessTPGFilesHandler.SaveToDataBase(TourML tourMLObj) in d:\AmiraProject\SourcesOfAmira-Tour\Amira\Amira.Merger.WorkerRole\Handlers\ProcessTPGFilesHandler.cs:line 161 at Amira.Merger.WorkerRole.Handlers.ProcessTPGFilesHandler.DeserializeAndSaveData() in d:\AmiraProject\SourcesOfAmira-Tour\Amira\Amira.Merger.WorkerRole\Handlers\ProcessTPGFilesHandler.cs:line 139 at Amira.Merger.WorkerRole.Handlers.ProcessTPGFilesHandler.Handle(StartProcessTPGFiles message) in d:\AmiraProject\SourcesOfAmira-Tour\Amira\Amira.Merger.WorkerRole\Handlers\ProcessTPGFilesHandler.cs:line 122 at lambda_method(Closure , Object , Object ) at NServiceBus.Unicast.HandlerInvocationCache.Invoke(Object handler, Object message, Dictionary2 Dictionary) in :line 0 at NServiceBus.Unicast.HandlerInvocationCache.InvokeHandle(Object handler, Object message) in :line 0 at NServiceBus.Pipeline.Behaviors.LoadedMessageHandlers.b_ 2(Object handlerInstance, Object message) in : line 0 at NServiceBus .Pipeline.Behaviors.InvokeHandlersBehavior.DispatchMessageToHandlersBasedOnType(IBuilder builder, LogicalMessage toHandle, LoadedMessageHandlers loadedHandlers, BehaviorContext context) in:line 0 at NServiceBus.Pipeline.Behaviors.InvokeHandlersBehavior.Invoke(BehaviorContext context, Action next) in:line 0 at NServiceBus.Pipeline .BehaviorChain.InvokeNext(BehaviorContext context) in :line 0 at NServiceBus.Pipeline.BehaviorChain.<>c _DisplayClass1.b_0() in :line 0 at NServiceBus.Sagas.SagaPersistenceBehavior.Invoke(BehaviorContext context, Action next) in :line 0 at NServiceBus.Pipeline.BehaviorChain.InvokeNext(BehaviorContext context) in :line 0 at NServiceBus.Pipeline.BehaviorChain.< >c _DisplayClass1.b_ 0() in:line 0 at NServiceBus.Pipeline.Behaviors.LoadHandlersBehavior.Invoke(BehaviorContext context, Action next) in:line 0 at NServiceBus.Pipeline.BehaviorChain.InvokeNext(BehaviorContext context) in:line 0 at NServiceBus.Pipeline.BehaviorChain.<>c _DisplayClass1.b_0() in :line 0 at NServiceBus.Pipeline.Behaviors.CallbackInvocationBehavior.Invoke(BehaviorContext context, Action next) in :line 0 at NServiceBus.Pipeline.BehaviorChain.InvokeNext(BehaviorContext context) in :line 0 at NServiceBus.Pipeline.BehaviorChain .<>c _DisplayClass1.b_ 0() in :line 0 at NServiceBus.Pipeline.Behaviors.ApplyIncomingMessageMutatorsBehavior.Invoke(BehaviorContext context, Action next) in :line 0 at NServiceBus.Pipeline.BehaviorChain.InvokeNext(BehaviorContext context) in :line NServiceBus.Pipeline.BehaviorChain.<>c _DisplayClass1.b_で 00() in :line 0 at NServiceBus.Pipeline.Behaviors.ExtractLogicalMessagesBehavior.Invoke(BehaviorContext context, Action next) in :line 0 at NServiceBus.Pipeline.BehaviorChain.InvokeNext(BehaviorContext context) in :line 0 at NServiceBus.Pipeline.BehaviorChain .<>c _DisplayClass1.b_ 0() in :line 0 at NServiceBus.Pipeline.Behaviors.RaiseMessageReceivedBehavior.Invoke(BehaviorContext context, Action next) in :line 0 at NServiceBus.Pipeline.BehaviorChain.InvokeNext(BehaviorContext context) in :line NServiceBus.Pipeline.BehaviorChain.<>c _DisplayClass1.b_で 00() in :line 0 at NServiceBus.Pipeline.Behaviors.ApplyIncomingTransportMessageMutatorsBehavior.Invoke(BehaviorContext context, Action next) in :line 0 at NServiceBus.Pipeline.BehaviorChain.InvokeNext(BehaviorContext context) in :line 0 at NServiceBus.Pipeline.BehaviorChain .<>c _DisplayClass1.b__0() : 行 0 の NServiceBus.UnitOfWork.UnitOfWorkBehavior.Invoke(BehaviorContext コンテキスト、次のアクション) : 行 0*

誰かがこれで私を助けることができますか? ありがとう

Azure で実行されているバスにコマンドを発行する必要があるイベントを消費する、MSMQ から実行されている既存のサービスバスがあります。

Azure を外部に公開し、内部メッセージ用に msmq を保持しています。

これを達成するために送信専用バスのインスタンスを新たに作成しようとしましたが、運が悪かったので、いくつかのポインター/コード サンプルをいただければ幸いです。

編集

この質問に対する答えが見つかりませんでした。現時点での回避策は、トランスポート プロトコルとして Azure を実行する nservicebus をホストする Web API をセットアップすることです。したがって、MSMQ コンシューマーが API を呼び出し、その API がコマンドを Azure バスに送信します。理想的ではありません...まったく、それが私が思いついたものです。

EDIT2

少し異なるが、ゲートウェイ構成に関する関連する質問を作成しました: Nservicebus msmq to azure queue using gateway

nservicebus で開始しようとしています。私の意図は、少なくともエンドポイントがサブスクライブしようとしているログ メッセージを取得することです。だから、次のようなメッセージのメッセージハンドラーを作成しました

契約 OrderAccepted は次のように定義されます。

NServiceBus のドキュメントによると、サブスクライバーの .config ファイルを変更するだけで十分です。

ただし、サブスクライバー ホストNServiceBus.Host.exeを起動すると、サブスクライブしようとしているというログ メッセージが表示されず、busstop.backend キューにサブスクリプション要求メッセージがありません。

ありがとう。