jms

0熱

1答えて

おはようございます。 1）私はJMSProducer、ActiveMQ Queryを作成し、いくつかのメッセージを送信するシンプルなアプリケーションを持っています。 2）私は、ActiveMQ Queryのサブスクライバであるアプリケーションも持っています（上記のアプリケーションからメッセージを受け取ります）。これは状況です：私は加入者のAppに別のサーバ設定を作成して、異なるポートで一度に

0熱

1答えて

すぐに現在のTXステータスを無視してJMSメッセージを送信する

簡潔に、私は春から入手した超簡単なJMS設定を使用します。ガイド：https://spring.io/guides/gs/messaging-jms/。私の場合は、私はTXが失敗した場合でも、同様STH（kotlinコード）トランザクションメソッドからJMSメッセージを送りたいということです：ない場合 @Service open class MyService(private val t: J

0熱

1答えて

Alpakka JMSトランザクション

私はAlpakkaとそのJMSコネクタで遊んで、Oracle AQからデータをデキューします。私は、以下の非常に基本的な実装を、thisガイドに従って実行することができます。私はそれをトランザクションにすることができますので、例外がスローされるとメッセージが失われないことを保証できます。 object ConsumerApp extends App { implicit val sys

0熱

1答えて

Spring起動時にセッションを閉じるJMS CachingConnectionFactory

私のJMS構成は次のようになっています（Springブート1.3.8）。 @Configuration @EnableJms public class JmsConfig { @Autowired private AppProperties properties; @Bean TopicConnectionFactory topicC

0熱

1答えて

Apache CamelとJMSクラスタ（分散キュー）

分散メッセージキューでCamelを使用するには？基本的に私は3つのサービスからなるシステムを持っています。ここで、AはSOAPクライアントとの同期境界です。 AコールサービスC が、代わりにサービスBから結果セットを取得します。。高可用性を保証するために、各サービスの複数のインスタンスが実行されます。要求する結果が呼び出されたサービスと異なるサービスでなければならないため、非同期メッセージング（

0熱

1答えて

Wildfly 10/11の実行時にプログラムによってjmsキューを追加するには？

以下のコードは、実行時にWildfly 9.0.1で問題なくJMSキューを作成します。 Wildfly 10と11では、hornetq-serverがactivemqに置き換えられました。それをWildfly 10/11に正しく移行するには？ありがとうございます。 JMS-実装は、Apache ActiveMQのArtemis.The次の例にHornetQのから変更Wildfly 10で pri

6熱

1答えて

HornetQ永続性がファイルを削除していない

私のアプリケーションでは、HornetQ 2.4.1がメッセージジャーナルファイル（時には何千ものファイル）を積み重ねていることに気がつきました。私はJMSキュー経由でHornetQを使用しています。ワイルドフライ8.2。通常、サーバーインスタンスを起動するとき、HornetQには3つのメッセージングジャーナルとロックファイルがあります。 HQ221014: 54% loaded をファイル、うま

0熱

1答えて

Spring JMSでFQQNにアクセスするには？次のように

マイアルテミスブローカーが設定されています。 <address name="PublishSubscribeWithPreDefinedQueues"> <multicast> <queue name="Queue1"/> <queue name="Queue2"/> </multicast> </address> にはどうすればQUEUE1に接続する

1熱

1答えて

jms、weblogicとのバネ統合、メッセージがチャネルに消費された後でもメッセージがキューに表示される

weblogic jmsとのバネ統合を使用しています。私の論理はjsonオブジェクトをjmsキューに入れ、それをキューからチャネルに消費し、それを検証し、特定のフィールドに基づいてルーティングします。エラーがある場合は、修正してキューに戻してください。私には2つの問題があります。 1.メッセージがオブジェクトに消費されるとき、私はまだオブジェクトをweblogicの管理コンソールで保留中であると見

0熱

1答えて

ActiveMQとMDBs - 古いメッセージを消費することを好む（FIFOを優先する）

同じMDBの〜50個のインスタンス（セッション）によって消費されるActiveMQのキューがあります。問題は、キューが多くのメッセージを受信し、さまざまな分のメッセージを大量に受信することがあることです。消費者は新しいメッセージを引き出しています。古いメッセージは引き出されず、キューはほとんど空になります。キューがいっぱいになっていると（消費者よりもメッセージが多い）、古いメッセージはまったく消