IBM MQ JMS 拡張機能の使用

接続ファクトリーを作成するために、アプリケーションは以下の例で示されているように MQConnectionFactory コンストラクターを使用できます。

MQConnectionFactory factory = new MQConnectionFactory();

このステートメントは、すべてそのプロパティーのデフォルト値で MQConnectionFactory オブジェクトを作成します。これは、アプリケーションがバインディング・モードでデフォルトのキュー・マネージャーに接続することを意味します。 アプリケーションをクライアント・モードで接続する場合、またはデフォルト以外のキュー・マネージャーに接続する場合、アプリケーションは接続を作成する前に MQConnectionFactory オブジェクトの適切なプロパティーを設定する必要があります。 これを行う方法については、 接続ファクトリーのプロパティーの設定を参照してください。

アプリケーションは、同様の方法で以下のタイプの接続ファクトリーを作成することができます。

• MQQueueConnectionFactory
• MQTopicConnectionFactory
• MQXAConnectionFactory
• MQXAQueueConnectionFactory
• MQXATopicConnectionFactory

例えば、次のようなコードがあるとします。

MQConnectionFactory factory = new MQConnectionFactory();
.
factory.setTransportType(WMQConstants.WMQ_CM_CLIENT);
factory.setQueueManager("QM1");
factory.setHostName("HOST1");
factory.setPort(1415);
factory.setChannel("QM1.SVR");

このコードは MQConnectionFactory オブジェクトを作成した後、オブジェクトの 5 つのプロパティーを設定します。 それらのプロパティーを設定すると、アプリケーションは QM1.SVR という名前の MQI チャネルを使用してクライアント・モードでキュー・マネージャー QM1 に接続します。 キュー・マネージャーは HOST1 というホスト名を持つシステムで稼働し、キュー・マネージャーのリスナーはポート番号 1415 で listen します。

Queue オブジェクトを作成するために、アプリケーションは以下の例で示されているように MQQueue コンストラクターを使用できます。

MQQueue q1 = new MQQueue("Q1");

このステートメントは、すべてそのプロパティーのデフォルト値で MQQueue オブジェクトを作成します。 このオブジェクトは、ローカル・キュー・マネージャーに属する Q1 という IBM MQ キューを表します。 このキューは、ローカル・キュー、別名キュー、またはリモート・キュー定義のいずれかです。

MQQueue コンストラクターの代替形式は、以下の例に示されているように、2 つのパラメーターを持ちます。

MQQueue q2 = new MQQueue("QM2", "Q2");

このステートメントによって作成される MQQueue オブジェクトは、キュー・マネージャー QM2が所有する Q2 という IBM MQ キューを表します。 このようにして識別されるキュー・マネージャーは、ローカル・キュー・マネージャーまたはリモート・キュー・マネージャーのいずれかです。 リモート・キュー・マネージャーの場合は、アプリケーションがこの宛先にメッセージを送信するときに、 WebSphere MQ がメッセージをローカル・キュー・マネージャーからリモート・キュー・マネージャーに経路指定できるように IBM MQ を構成する必要があります。

MQQueue コンストラクターは単一パラメーターとしてキュー Uniform Resource Identifier (URI) を受け入れることもできます。 キュー URI は、 IBM MQ キューの名前と、オプションでそのキューを所有するキュー・マネージャーの名前、および MQQueue オブジェクトの 1 つ以上のプロパティーを指定するストリングです。 以下のステートメントにはキュー URI の例が含まれています。

MQQueue q3 = new MQQueue("queue://QM3/Q3?persistence=2&priority=5");

このステートメントによって作成される MQQueue オブジェクトは、キュー・マネージャー QM3 が所有する Q3 と呼ばれる IBM MQ キューを表し、この宛先に送信されるすべてのメッセージは持続し、優先順位 5 を持ちます。 キュー URI について詳しくは、 Uniform Resource Identifier (URI)を参照してください。 MQQueue オブジェクトのプロパティーを設定する別の方法については、 宛先のプロパティーの設定を参照してください。

アプリケーションは、以下の例で示されているように MQTopic コンストラクターを使用して Topic オブジェクトを作成することができます。

MQTopic t1 = new MQTopic("Sport/Football/Results");

このステートメントは、すべてそのプロパティーのデフォルト値で MQTopic オブジェクトを作成します。 オブジェクトは Sport/Football/Results という名前のトピックを表します。

MQTopic コンストラクターはパラメーターとしてトピック URI を受け入れることもできます。 トピック URI は、トピックの名前と、オプションで MQTopic オブジェクトの 1 つ以上のプロパティーを指定するストリングです。 以下のステートメントにはトピック URI の例が含まれています。

MQTopic t2 = new MQTopic("topic://Sport/Tennis/Results?persistence=1&priority=0");

このステートメントによって作成される MQTopic オブジェクトは、Sport/Tennis/Resultsというトピックを表し、この宛先に送信されるすべてのメッセージは非永続で、優先順位 0 を持ちます。 トピック URI について詳しくは、 Uniform Resource Identifier (URI)を参照してください。 MQTopic オブジェクトのプロパティーを設定する別の方法については、 宛先のプロパティーの設定を参照してください。

例えば、次のようなコードがあるとします。

MQQueue q1 = new MQQueue("Q1");
.
q1.setPersistence(WMQConstants.WMQ_PER_PER);
q1.setPriority(5);

このコードは MQQueue オブジェクトを作成した後、オブジェクトの 2 つのプロパティーを設定します。 それらのプロパティーを設定すると、その宛先に送信されるメッセージはすべて永続メッセージとなり、優先順位は 5 になります。

アプリケーションは、以下の例で示されているとおり、同様の方法で MQTopic オブジェクトのプロパティーを設定することができます。

MQTopic t1 = new MQTopic("Sport/Football/Results");
.
t1.setPersistence(WMQConstants.WMQ_PER_NON);
t1.setPriority(0);

このコードは MQTopic オブジェクトを作成した後、オブジェクトの 2 つのプロパティーを設定します。 それらのプロパティーを設定すると、その宛先に送信されるメッセージはすべて非永続メッセージとなり、優先順位は 0 になります。