JMSによるHestiaとの接続のバックアップソース(No.5) - ADOS Developer's Site

バックアップ一覧
差分を表示
現在との差分を表示
バックアップを表示
JMSによるHestiaとの接続へ行く。
- 1 (2005-10-07 10:03:16 (金))
- 2 (2005-10-07 11:07:14 (金))
- 3 (2005-10-07 14:41:11 (金))
- 4 (2005-10-12 14:24:25 (水))
- 5 (2005-10-17 10:17:59 (月))
RIGHT:[[目次>Hestia Hacks]]|[[前>2アクションPIPの回答側処理]]|[[次>ServiceContentのXMLファイルを入力して送信]]

目次

#contents

*概要 [#g9d276f6]

JMSによるEISとHestiaの接続について解説します。

サンプルプログラム全体を以下に示します。

【PIPSenderJMS.java】
 1 : import java.io.FileInputStream;
 2 : import java.util.Date;
 3 : import java.util.Properties;
 4 : 
 5 : import com.ados.hestia.parser.rnbm.access.Validator;
 6 : import com.ados.hestia.parser.rnbm.exchange.Container;
 7 : import com.ados.hestia.parser.rnbm.exchange.PayloadContainer;
 8 : import com.ados.hestia.parser.rnbm.exchange.StatusContainer;
 9 : import com.ados.hestia.parser.rnbm.model.RootElement;
 10 : import com.ados.hestia.parser.rnbm.particle.DateTimeStamp;
 11 : import com.ados.hestia.parser.rnbm.particle.ServiceContent;
 12 : import com.ados.hestia.parser.rnbm.repository.Repository;
 13 : import com.ados.hestia.sdk.Configuration;
 14 : import com.ados.hestia.sdk.Connection;
 15 : import com.ados.hestia.sdk.message.JMSMessageExchanger;
 16 : import com.ados.hestia.sdk.rnbm.randomgenerator.RootElementGenerator;
 17 : import com.ados.hestia.sdk.session.InitiationSession;
 18 : import com.ados.hestia.sdk.session.Session;
 19 : import com.ados.hestia.utils.UID;
 20 : 
 21 : public class PIPSenderJMS {
 22 : 
 23 :   public static void main(String[] args) {
 24 :     try {
 25 :       Properties prop = new Properties();
 26 :       prop.load(new FileInputStream("sample.properties"));
 27 :       String HOST = prop.getProperty("HOST");
 28 :       String USER = prop.getProperty("USER");
 29 :       String PASS = prop.getProperty("PASS");
 30 :       String RECEIVE_QUEUE = prop.getProperty("RECEIVE_QUEUE");
 31 :       String SEND_QUEUE = prop.getProperty("SEND_QUEUE");
 32 :       String FACTORY = prop.getProperty("FACTORY");
 33 :       String SENDER = prop.getProperty("SENDER");
 34 :       String RECEIVER = prop.getProperty("RECEIVER");
 35 :       String HANDLER_ID = prop.getProperty("HANDLER_ID");
 36 : 
 37 :       Connection connection = new Connection(HOST, USER, PASS,
 38 :           Connection.EXCHANGE_MODE_JMS, RECEIVE_QUEUE, SEND_QUEUE,
 39 :           FACTORY, HANDLER_ID);
 40 :       JMSMessageExchanger exchanger = new JMSMessageExchanger(connection,
 41 :           Configuration.getInstance());
 42 : 
 43 :       RootElement re = Repository.getDefault().getResolver()
 44 :           .resolveByVersion("0C1",
 45 :               "Pip0C1AsynchronousTestNotification", "R01.02.00");
 46 :       RootElementGenerator reg = new RootElementGenerator(re);
 47 :       reg.process();
 48 :       ServiceContent sc = new ServiceContent("0C1", re);
 49 :       sc.setGlobalDocumentFunctionCode("Request");
 50 :       sc.setDocumentGenerationDateTime(new DateTimeStamp());
 51 :       sc.setDocumentIdentifier((new UID()).toString());
 52 :       sc.setElementValue(
 53 :           "fromRole/PartnerRoleDescription/PartnerDescription/BusinessDescription/GlobalBusinessIdentifier",
 54 :               SENDER);
 55 :       sc.setElementValue(
 56 :           "toRole/PartnerRoleDescription/PartnerDescription/BusinessDescription/GlobalBusinessIdentifier",
 57 :               RECEIVER);
 58 : 
 59 :       Session session = new InitiationSession(new PayloadContainer(
 60 :           new Date(), SENDER, RECEIVER, (new UID()).toString(), sc,
 61 :           null));
 62 :       SampleUtils.printSessionState("created", session);
 63 :       PayloadContainer request = session.getMessageToSend();
 64 :       SampleUtils.printSessionState("got", session);
 65 :       SampleUtils.printContainerInformation(request);
 66 :       SampleUtils.printServiceContent(request.getServiceContent());
 67 :       new Validator(request.getServiceContent().getElement()).validate();
 68 :       exchanger.sendMessage(request);
 69 :       SampleUtils.printSessionState("sent", session);
 70 : 
 71 :       int time = 0;
 72 :       boolean loop = true;
 73 :       while (loop) {
 74 :         Thread.sleep(5000);
 75 :         exchanger.hit();
 76 :         SampleUtils.printSessionState("loop=" + time++, session);
 77 : 
 78 :         Container container = exchanger.receiveMessage();
 79 :         if (container != null) {
 80 :           SampleUtils.printContainerInformation(container);
 81 :           session.pushStatus((StatusContainer) container);
 82 :           SampleUtils.printSessionState("pushed", session);
 83 :           loop = false;
 84 :         }
 85 :       }
 86 : 
 87 :     } catch (Exception e) {
 88 :       e.printStackTrace();
 89 :     }
 90 :   }
 91 : 
 92 : }

*JMSMessageExchangerの使用 [#lda1768c]

JMSMessageExchangerはJMSによる接続を行うクラスです。また、 Connectionコンストラクタには、JMSでの接続を意味するEXCHANGE_MODE_JMSを指定します。

 37 :       Connection connection = new Connection(HOST, USER, PASS,
 38 :           Connection.EXCHANGE_MODE_JMS, RECEIVE_QUEUE, SEND_QUEUE,
 39 :           FACTORY, HANDLER_ID);
 40 :       JMSMessageExchanger exchanger = new JMSMessageExchanger(connection,
 41 :           Configuration.getInstance());

一般的な処理の記述方法は、DirectMessageExchangerと同じです。JMSMessageExchangerとDirectMessageExchangerは共通の上位クラスMessageExchangerを持ちます。

|関連クラス|機能|h
|com.ados.hestia.sdk.Connection|Hestiaのネットワークアドレス等のプロパティのラッピング。|
|com.ados.hestia.sdk.message.JMSMessageExchanger|HestiaとJMS接続を行う。|
|com.ados.hestia.sdk.message.MessageExchanger|JMSMessageExchangerとDirectMessageExchangerの上位クラス。|

*Hestia側ハンドラの設定 [#f5429164]

Hestia側に、JMSで接続するためのハンドラを設定する必要があります。下記のように設定します。

【{HestiaHOME}/server/default/data/bridgehandlers.xmlの記述例】
 <handlers>
	<handler>
		Handler.ID=EIS　<- 任意の値
		Handler.Priority=0　<- 任意の値
		Communicator.Type=JMS　<- 固定値
		JMS.Queue.Receive=queue/hestiaIncomingQueue　<- デフォルト値
		JMS.Queue.Send=queue/hestiaOutcomingQueue　<- デフォルト値
		JMS.Factory=UIL2ConnectionFactory　<- デフォルト値
		Filter.Partner.Local=Any　<- 任意の値
		Filter.Partner.Remote=Any　<- 任意の値
		Filter.Pip=Any　<- 任意の値
	</handler>
	<handler>
		・・・
	</handler>
 </handlers>
		[ トップ ] [ 一覧 \| 単語検索 \| 最終更新 \| ヘルプ ]