message-queue

1熱

1答えて

jmsメッセージからヘッダーとプロパティを除いたjmsメッセージテキストのみを抽出します。 JMSヘッダを抽出するには：msg.getJMSCorrelationID(); JMSプロパティを抽出するにはjmsMessage.getPropertyNames() メッセージからテキスト値のみを取得する方法はありますか？以下のサンプルメッセージで、「hello queue」のみを抽出します。これを

0熱

1答えて

RESTからメッセージキュー

への通信方法REST Microserviceは、ハイブリッドである別のMicroserviceと通信することができます。つまり、RESTとMessage Queueと通信できます。 APIゲートウェイの例。外の世界では、彼はREST経由でApp、Mobilephoneと通信することができますが、バックエンドからの通信はメッセージキュー経由です。使用例：私のホームページはデータベースから車両を

0熱

1答えて

Qpid Proton：2つの宛先にメッセージを送信

現在、私は単一のキュー "devQueue"にメッセージを送信できます。メッセージが「devQueue」に届くと、それは「localQueue」にも送られる必要があります。私はこの実装が挑戦的であると感じています。私は別のクラス "local_send"を "class1"クラスから呼び出そうとしましたので、 "localQueue"（下のコードに示すように）の他の行き先に接続できますが、運があり

0熱

1答えて

nettyチャネルをキューに渡し、後で別のスレッドの書き込みに使用することは有効ですか？

次の設定があります。 APPID（接続されたクライアントあたり）と呼ばれる一意の識別子に基づいて、メッセージキュー（私の場合はLinkedBlockingQueues）の設定された数を越えインバウンド・クライアントメッセージを拡散メッセージ分配は、あります：私も答える必要と public class MessageDistributor { private final List<Blo

0熱

1答えて

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

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

0熱

1答えて

プロセス間通信における最善のアプローチは何ですか？

こんにちは私は.netでアプリケーションを開発しようとしています。それは.netコアです。それはWebアプリケーションです。同じマシンで1つのプロセスを実行しています。これはCプログラミングで書かれています。私は、私の.netアプリケーションとプロセスの間で双方向の通信をしたい。どのメカニズムが適しているのですか？私はLinux環境で私の.netアプリケーションをホストし、プロセスもLinux環境

1熱

2答えて

RabbitMQの起動に失敗しました。TCP接続は成功しましたが、Erlangの配布は失敗しました。

WindowsシステムでRabbitMQを学びインストールするだけです。私はErlang VMとRabbitMQをデフォルトのフォルダではなくカスタムフォルダにインストールします（両方とも）。その後、コンピュータを再起動しました。 rabbitmqctl status しかしリターン：ところで、マイコンピュータ名が "NULL" である IのCD のRabbitMQ/フォルダsbinにしてコ

0熱

1答えて

PubSub経由でメッセージを送信し、将来の日付で受信する方法

私は春のブートプロジェクトでPubSubを使い始めています。PubSubを使ってこれが可能かどうかわからない機能を実装する予定です。トピックにメッセージを公開する必要があり、サブスクライバはすぐにメッセージを受信する必要はありません。サブスクライバは5日以内にメッセージを受信する必要があります（将来の任意の日付）。これが可能かどうかわかりませんが、ドキュメントで何も見つかりませんでした。これが

0熱

1答えて

C：メッセージキューを開くことができません

私はOpenSuse 42.3 Leapに取り組んでいます。これは私の最初のUnixメッセージ待ち行列であり、単純に新しい待ち行列を開くという基本的な問題があります。私のオリジナルの問題は、私は2つのキューを開くことができませんでしたが、数回の試行の後、私はこの奇妙な行動に減少問題を抱えていた：私はこれに #include<stdio.h> #include <mqueue.h> int

0熱

1答えて

ActiveMqのトピック内のメッセージが配信されるユーザの最大数を制限する

ActiveMqインスタンスがあり、トピックをリスンするクライアントが100人いるとします。新しいメッセージがトピックに公開されると、それを受信するサブスクライバの数を制限できますか（例10のみ）？他のメッセージングコンポーネントがこれを行うことができますか、回避策/強化されたベストプラクティスがある場合は、