は、私はActiveMQのはここに適切なツールであれば、私の考えは、それまでに消費され、タスクを投稿するにActiveMQを使用していたので...</p> <p>私は、タスクキューおよび複数のコンシューマを持ってわからないActiveMQのメッセージ

Question

をキャンセル消費者。

しかし、私はそれがまだ処理されなかった場合は、タスクをキャンセルできるようにする必要があります...

はActiveMQのでキューからメッセージを削除するためのAPIはありますか？

Destination destination = session.createQueue(TOPIC_NAME); 
MessageProducer producer = session.createProducer(destination); 
ObjectMessage message = session.createObjectMessage(jobData); 
producer.send(message); 
... 
producer.cancel(message); (?) 

ユースケースは、何らかの理由で、タスクを実行する必要がなくなり、タスクがリソースを消費するということです。

Answer 1

ActiveMQは、この種の操作を可能にするJMXインターフェイスを公開します。 Queueをモデル化するMBean（たとえば、org.apache.activemq：type = broker、brokerName = amq、destinationType = Queue、destinationName = my_queue）は、メソッドremoveMessage（String id）を公開します。また、特定のパターンに一致するメッセージを削除するメソッドもあります。

私の知る限り、この機能はJMXの外部に公開されていません。

しかし...

私は、特定のメッセージに取り組んでJMX操作のみをメモリにページングされるメッセージに取り組むことを嫌な気持ちを持っています。デフォルトでは、通常、キューの先頭に最も近い400のメッセージになります。私はこれがセレクタ操作に当てはまることは知っていますが、JMXについてはわかりません。

一部のActiveMQメッセージストア（JDBCストアなど）は、基礎となるメッセージデータにアクセスして操作する方法を提供する場合もあります。リレーショナルデータベースでは、JMS操作で「飛んでいる」メッセージはデータベースレベルでロックされるため、通常これは安全です。しかし、これは簡単な仕事でなければならないもののための多くの面倒です。

JMSが本当にこの仕事のための適切な技術だと思いますか？ランダムアクセスのためのものではありません。おそらく、ある種の分散データキャッシュがうまくいくでしょう（jgroups、Hazelcast、...）？

Answer 2

メッセージの有効期限を設定するにはどうすればよいですか？ http://activemq.apache.org/how-do-i-set-the-message-expiration.html

メッセージが特定の時間枠内で処理/使用されていない場合に削除する場合は、メッセージの有効期限がわかります。