問題タブ [producer]

安心して使用し、エンティティマネージャーを管理したいと考えています。WEB-INF に persistence.xml リソースと beans.xml があります。entitymanager を以下で使用したい:

私のプロデューサーは次のとおりです。

私のエンティティマネージャーはnullです。誰でも助けることができますか？

私の残りのコードは次のとおりです。

UserDao は次のとおりです。

私のポンは：

EntityDao では、@Inject を持つ EntityManager が null であり、プロデューサーが機能しません。感謝している。

ActiveMQ のドキュメントには、Session および MessageProducer オブジェクトはスレッドセーフではないと記載されています。永続的なメッセージを生成できる一連のスレッドがある場合、特定の送信操作が成功したかどうかを認識して、それらを ActiveMQ に正しく送信する方法を教えてください。

1. ワーカー スレッドごとに個別の Session/MessageProducer を用意します。
2. プロデューサ スレッドの明示的なセットを作成し、BlockingQueue を介してそれらにメッセージを渡します (送信が成功したかどうかを調べる方法は?)。
3. 前のケースで Future<> を使用して、ActiveMQ で永続化されたメッセージの成功状態を取得します。
4. 各 MessageProducer.sendMessage() 呼び出しを同期ブロックでラップするだけです。

または、そのような場合のベストプラクティスがあるかもしれません。ありがとう。

こんにちは、次の問題があります。@inject プライベート Gson gson なしでクラスをロードすると、正常に実行されますが、配置すると例外がスローされます。

gson を呼び出すクラス。

クリエイター：

Gson を呼び出す Bean を呼び出すクラス

例外

それぞれに期日と作成日がある注文の DB があります。最大 4 つの注文をルートに取り込み、同時に処理したいと考えています。各注文の処理には 10 ～ 20 分かかる場合があります。しかし、ダウンタイムがないように、すべてのスレッドを可能な限り継続したいと考えています。

これが私が今持っているものです：

getNextOrderDAO 関数は、期日を過ぎた最も古い注文を作成日別に返します。受注はすぐに試行されます。

現在の問題は、タイマーの結果として着信注文が JMS ルートに山積みになりgetNextOrder、はるかに古い注文を返すと、キューでかなり遅れることです。

DB が最も古い 4 つの注文に対してポーリングされ、それらが同時に実行されるように、これらのルートをどのように構築できるかについてのアイデアはありますか? DAO への変更は許容されます。

マルチスレッドプロデューサーの種類はありますか?

提案を事前にありがとう！