jms

2熱

1答えて

メッセージブローカーとしてRabbitMQを使用するようにJB EAP7を設定するのが難しいです。私はrabbitmqモジュールを作成し、スタンドアロンのha.xmlにグローバルモジュールとして定義しました。モジュール/システム/層/ベース/ COM/RabbitMQの/メイン/ module.xml： <module xmlns="urn:jboss:module:1.1" name="co

0熱

2答えて

複数のコンシューマによる処理オーダーを保証

2つのリクエスト（AとB）が順番にキューに送られました。ただし、2人の消費者があり、同時に2つの要求を処理します。質問：2つのリクエストが順番に処理されるようにするにはどうすればよいですか（A完了後にBが処理されます）。

0熱

1答えて

Glass Fishを使用したJMSパブリッシュ/サブスクライバ - WebページでMDBに送信されたデータを表示する方法

データを収集してJMSトピックに送信するWebアプリケーションフォームがあります。トピックから、私はメッセージ駆動型Beanを介してEJBを使用して取得できます。取得したデータをjsfページに表示するにはどうすればよいですか？

1熱

2答えて

Apache Camel - Websphere MQ統合

私はapache-camelソリューションを使用しているアプリケーションを持っていて、Websphere MQ Serverにjmsを通してメッセージを送信したい場合は、jmsプロパティJMS_IBM_MQMD_MsgIdをMQMDフィールドMQMD.MsgIdに変換してください。 exchange.getIn().setHeader(WMQConstants.JMS_IBM_MQMD_MSGID

0熱

1答えて

Message Driven BeanはJMSメッセージを同期して処理できますか？

MDBには、Java EEコンテナによってonMessage（）メソッドが呼び出され、メッセージが渡されます。これは、クライアント（MDB）がトピックまたはキューで受信を呼び出す必要がなく、コンテナ/プロバイダが自動的にメッセージを配信するメッセージの非同期消費を可能にします。メッセージの同期消費にMDBを使用できますか？ PostConstructメソッドや、ある宛先のonMessageメソ

0熱

1答えて

Destinationがダウンしている場合、IBM MQメッセージを確実に送信するにはどうすればよいですか？

私はIBMキューにメッセージを送信する必要があります。何らかの理由でQueueManager内部に存在するキューが停止しているか、またはIBM MQブローカーがダウンしているか、ネットワークの問題があると、今 Session session = queueConnection.createSession(true, QueueSession.AUTO_ACKNOWLEDGE);

0熱

1答えて

トピック内にメッセージをパブリッシュするには、トランザクション内で確実に行う方法はありますか？

だから、ここに要件があります。トランザクションは、トランザクションが失敗した場合、我々は0 返し、その後成功した場合は、トランザクション内でを行うべきトピックにメッセージを公開するプロセスは、その後、我々は返す1 私はトピックにメッセージを公開する方法を知っています。私はトピックに公開するためにJMSテンプレートを使用しています。 jmsTemplate.convertAndSend(topi

0熱

1答えて

JMSで保留中のメッセージを受信していません

私はActiveMQとJMSを使用しています私はキューにObjectMessageを作成しました。私はそれを受け取ることができません。既にキューで利用可能なメッセージを見てください。メッセージを受信するための私のコードは、任意のより多くの明快さやコードが必要な場合は、お問い合わせください public class RecieveObjectQueue { public stati

0熱

1答えて

組み込みブローカActiveMQのコンフィグレーション

これは、メッセージを埋め込みブローカに送信するための設定です。また、最初のBeanメソッドは、ブローカの作成と起動だけに使用されます。インスタンスは返されません。このコードはブローカーを開始しますか？ JMSテンプレートのsendメソッドを使用して、以下のトピックにメッセージを送信しました。ブローカを作成して実行するためのcreatebrokerserviceを作成しました。 @Configur

0熱

1答えて

ActiveMQの

ERROR org.apache.activemq.broker.BrokerService - Failed to start Apache ActiveMQ ([localhost, null], java.io.IOException: org/apache/activemq/store/NoLocalSubscriptionAware) INFO org.apache.activemq