activemq

0熱

1答えて

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

0熱

1答えて

ActiveMQは、期限切れのメッセージを失敗したメッセージとは異なるキューに移動します。

ActiveMQキューにメッセージが蓄積される可能性のあるユースケースがあります。目標はより高い優先度を持ち、より新しいメッセージが最初に実行されることです。ある時間よりも古い高優先度メッセージは、より低い優先度で実行する必要があります。私が読んだところでは、JMSセレクターはNOW（）の概念をサポートしていません。（すなわち） JMSTimestamp < NOW() - 30 MINUTE

0熱

1答えて

アクティブなソケットに巨大なソケット番号

アクティブなソケットがあるという問題があります。 ActiveMQドキュメントによれば、非アクティブなためソケットは閉じられます。しかし、私のアプリケーションでは、いつかの後に、私は巨大なソケット接続があるため、非アクティブです。ここに私の設定です：クライアント構成がsoTimeoutの30代を持っている、のConnectionTimeout 10S Broker構成は、私は以下の例外を持ってい

4熱

1答えて

AWSではAmazon MQを提供していますが、どのようにLambdaを起動できますか？

Amazon MQサービスに関するすばらしいニュースですが、今では特定のキューのメッセージに対してどのようにラムダ関数（Node.js）をトリガーすることができるのかという疑問が生じますか？私は何とかPUTメッセージまたはキューからのメッセージを消費するためにラムダを発射することができますいくつかの他のトリガに掲載SNSトピックを得ることができる場合私は任意の提案...考えていましたか？

4熱

1答えて

エンドポイントが見つかりすることができませ：テスト、確認していないしてください、あなたのクラスパスが必要なキャメルコンポーネントジャー

が含まれている私はakka-camelを使用してメッセージを送受信しようとすると、下記のように生産者と消費者のためのサンプル例を作成しています：プロデューサー： import akka.actor.{Actor, ActorSystem, Props} import akka.camel.Producer class CamelJmsProducer extends Actor with

2熱

1答えて

ActiveMQコールのnpmモジュール

nodejsからActiveMQを呼び出すには、最適なnpmライブラリは何ですか？私は 'ストンプ'を試みましたが、時には有線で動作します。私はstompポート（61613）を使用するたびにを処理しましたが、TCPポート（61616）を使用すると、パケットサイズが最大であるというActiveMQログに例外がスローされます。

0熱

1答えて

Activemqを使用した場合のボトルネック

私はブローカーとしてactivemqを使用するプロジェクトに取り組んでいます。私の問題は、多くのリクエストと多くのデータがActivemqキューに置かれることです。何とか複数のActivemqインスタンスを持つ方法はありますか？私は複数のインスタンスを持つことができることを知っています。しかし、それらを管理する方法はわかりません。つまり、あるブローカーがビジー状態になると、インスタンスを使用しま

0熱

1答えて

送信メッセージMVC春にはActiveMQにnullポインタ例外

を与える私は、MVC、スプリングによって/ ActiveMQのからメッセージを送信し、reciveサンプルを実行しようとしています。しかし、私はこのエラーを取得するプロジェクトを実行するとき： java.lang.NullPointerException com.sarf.jms.MessageProducerBean.sendMessage(MessageProducerBean.ja

-1熱

2答えて

ActiveMQConsumer.receive（1000）はnullを返します

ACtiveMQにメッセージを書き込んでいますが、このメソッドでサンプルプログラムを実行していますActiveMessageConsumer.receive(1000)は常にnullというメッセージを返します。キューにはメッセージがありますが、依然としてそれらのメッセージを受信できません。 url = "http：//"; http://activemq.apache.org/connectio