ActiveMQをすぐに使う
ActiveMQは、Apacheの JMSサーバ。
ダウンロードしたバイナリのアーカイブを展開して、bin/activemq スクリプトを起動すると
TCPポート61616番でメッセージブローカが待ち受けを開始する。
JMSのクライアントは apache-activemq-*.jarをクラスパスに追加し、ActiveMQConnectionFactory (implements javax.jms.ConnectionFactory) を使ってメッセージブローカへの接続を得る(brokerURLプロパティには接続先を示す文字列をセットすること)。Springなら下記のように。
後は Queueなり Topicなり好きな方法でメッセージを交換すれば良い。
ダウンロードしたバイナリのアーカイブを展開して、bin/activemq スクリプトを起動すると
TCPポート61616番でメッセージブローカが待ち受けを開始する。
JMSのクライアントは apache-activemq-*.jarをクラスパスに追加し、ActiveMQConnectionFactory (implements javax.jms.ConnectionFactory) を使ってメッセージブローカへの接続を得る(brokerURLプロパティには接続先を示す文字列をセットすること)。Springなら下記のように。
<bean id="connectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://localhost:61616"/>
</bean>
後は Queueなり Topicなり好きな方法でメッセージを交換すれば良い。

0 件のコメント:
コメントを投稿
<< ホーム