cXML API の使用

表3-1 パブリック cXML メソッド

メソッド	パッケージ	説明
onMessage	com.bea.b2b.protocol.cxml.CXMLListener	送信された CXMLMessage を受信する。
deregister	com.bea.b2b.protocol.cxml.CXMLManager	この CXMLManager からアプリケーションの登録を解除する。プロパティセットを使用して登録を選択する。
getInstance	com.bea.b2b.protocol.cxml.CXMLManager	CXMLManager のインスタンスを取得する。
getSharedSecret	com.bea.b2b.protocol.cxml.CXMLManager	このトレーディングパートナの共有秘密を取得する。トレーディングパートナ名を使用して共有秘密を検索する。
register	com.bea.b2b.protocol.cxml.CXMLManager	この CXMLManager にアプリケーションを登録する。プロパティセットを使用して、このトレーディングパートナのコラボレーションアグリーメントを選択する。 cXML メッセージの送信に使用する。
getHttpStatusCode	com.bea.b2b.protocol.cxml.CXMLHttpStatusException	例外から HTTP ステータスコードを返す。
getAsString	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	cXML パートを文字列として取得する。
getDocument	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	関連付けられている XML ドキュメントを取得する。
getFromCredentialDomains	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドキュメントヘッダから From Credential Domain を取得する。
getFromCredentialIdentities	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドキュメントヘッダから From Credential Identity を取得する。
getIdentifier	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドメイン識別子またはメッセージ識別子を取得する。
getNodeValue	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	指定された XPath 式を使用してドキュメントノードの値を取得して、ドキュメントノードを検索する。複数のノードが XPath 式に一致した場合、最初のノードだけが使用される。
getSenderCredentialDomain	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドキュメントヘッダから Sender Credential Domain を取得する。
getSenderCredentialIdentity	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドキュメントヘッダから Sender Credential Identity を取得する。
getSenderSharedSecret	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドキュメントヘッダから Sender Credential Shared Secret を取得する。
getSenderUserAgent	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドキュメントヘッダから Sender User Agent を取得する。
getTimeStamp	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドキュメントタイムスタンプまたはメッセージタイムスタンプのいずれかを取得する。
getToCredentialDomain	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドキュメントヘッダから To Credential Domain を取得する。
getToCredentialIdentity	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドキュメントヘッダから To Credential Identity を取得する。
getVersion	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	ドキュメントバージョンを取得する。
setDocument	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	関連付けられている XML ドキュメントを設定する。
setNodeValue	com.bea.b2b.protocol.cxml.messaging.CXMLDocument	指定された XPath 式を使用してドキュメントノードの値を設定して、ドキュメントノードを検索する。
reply	com.bea.b2b.protocol.cxml.messaging.CXMLMessage	要求メッセージに応答する。このメソッドは、このオブジェクトが CXMLListener.onMessage() へのパラメータとして使用される場合にのみ有効。応答は、このメソッドの呼び出し後に非同期に送信できる。
getReplyDocument	com.bea.b2b.protocol.cxml.messaging.CXMLMessage	応答 cXML ドキュメントを取得する。
getRequestDocument	com.bea.b2b.protocol.cxml.messaging.CXMLMessage	要求 cXML ドキュメントを取得する。
send	com.bea.b2b.protocol.cxml.messaging.CXMLMessage	要求メッセージを送信する。このメソッドは、応答が受信されるまでブロックされる。応答には、getReplyDocument() を介してアクセスできる。
setCollaborationAgreement	com.bea.b2b.protocol.cxml.messaging.CXMLMessage	このメッセージが属するコラボレーションアグリーメントのコラボレーションアグリーメント ID を設定する。プロパティセットを使用してコラボレーションアグリーメントを選択する。
setReplyDocument	com.bea.b2b.protocol.cxml.messaging.CXMLMessage	応答 cXML ドキュメントを設定する。
setRequestDocument	com.bea.b2b.protocol.cxml.messaging.CXMLMessage	要求 cXML ドキュメントを設定する。
getHttpStatusCode	com.bea.b2b.protocol.cxml.messaging.CXMLMessageToken	HTTP ステータスコードを取得する。

prop.setProperty("BusinessProcess", businessProcess);
prop.setProperty("BusinessProcessVersion", businessProcessVersion);
prop.setProperty("DeliveryChannel", deliveryChannel);
prop.setProperty("thisTradingPartner", myTradingPartnerName);
prop.setProperty("otherTradingPartner", otherTradingPartnerName);
prop.setProperty("toRole", toRole);
prop.setProperty("Party", "duns4");

前節の初期化,で説明したとおり受信メッセージを初期化したら、そのメッセージを処理できます。そのためには、アプリケーションは以下のことを行う必要があります。

結果	理由
比較が実行されなかった	トレーディングパートナの共有秘密がコンフィグレーションされていない。
メッセージが拒否され、http ステータスコード 400（不正な要求）が表示された	要求メッセージを解析できなかった。この問題は、WebLogic Integration ランタイムで解決される。
メッセージが拒否され、http ステータスコード 401（不正なアクセス）が表示された	共有秘密が一致しない。
メッセージが拒否され、http ステータスコード 500（要求の転送不能）が表示された	リスナが適切にコンフィグレーションされていなかった。この問題は、WebLogic Integration ランタイムで解決される。

結果

理由

比較が実行されなかった

トレーディングパートナの共有秘密がコンフィグレーションされていない。

メッセージが拒否され、http ステータスコード 400（不正な要求）が表示された

要求メッセージを解析できなかった。この問題は、WebLogic Integration ランタイムで解決される。

メッセージが拒否され、http ステータスコード 401（不正なアクセス）が表示された

共有秘密が一致しない。

メッセージが拒否され、http ステータスコード 500（要求の転送不能）が表示された

リスナが適切にコンフィグレーションされていなかった。この問題は、WebLogic Integration ランタイムで解決される。

DOMImplementationImpl domi = new DOMImplementationImpl();

DocumentType dType =
domi.createDocumentType("request", null, "cXML.dtd");

org.w3c.dom.Document punchoutDoc = new DocumentImpl(dType);
CxmlElementFactory cf = new CxmlElementFactory(punchoutDoc);

// ヘッダ
cf.createHeaderElement(
// 送信元
cf.createFromElement(
cf.createCredentialElement(
"DUNS",
myTradingPartnerName,
null)),
// 送信先
cf.createToElement(
cf.createCredentialElement(
"DUNS",
otherTradingPartnerName,
null)),
// 送信者
cf.createSenderElement(
cf.createCredentialElement(
"AribaNetworkUserId",
"admin@acme.com",
otherSharedSecret),
"Ariba ORMS 5.1P4")),

punchoutDoc.appendChild(
cf.createCxmlElement(
// ヘッダ
cf.createHeaderElement(
// 送信元
cf.createFromElement(
cf.createCredentialElement(
"DUNS",
myTradingPartnerName,
null)),
// 送信先
cf.createToElement(
cf.createCredentialElement(
"DUNS",
otherTradingPartnerName,
null)),
// 送信者
cf.createSenderElement(
cf.createCredentialElement(
"AribaNetworkUserId",
"admin@acme.com",
otherSharedSecret),
"Ariba ORMS 5.1P4")),

/*
* Copyright (c) 2001 BEA
* All rights reserved
*/
package examples.ibcxmlverifier;

import java.io.*;
import java.util.*;
import javax.servlet.*;
import javax.servlet.http.*;

import org.w3c.dom.*;
import org.apache.html.dom.*;
import org.apache.xml.serialize.*;
import org.apache.xerces.dom.*;

import com.bea.b2b.protocol.cxml.messaging.*;
import com.bea.b2b.protocol.cxml.*;

import com.bea.eci.logging.*;

/**
* This example provides a simple test that will verify message flow of cXML
* peer-to-peer sending and receiving a cXML document.
* The two peers (Partner1 and Partner2) are running on a single WLS.
* Partner1 sends a PunchoutRequest to Partner2. Partner2 generates a
* PunchoutSetupResponse and returns it to Partner1. Shared Secrets are verified
* at both ends.
*/
public class Partner1Servlet extends HttpServlet
{
static final boolean DEBUG = true;

private final static String businessProcess = "PunchoutSetup";
private final static String businessProcessVersion = "1.1.009";
private final static String deliveryChannel = "CXMLPartnerVerifier1";
private final static String myTradingPartnerName = "CXMLPartnerVerifier1";
private final static String otherTradingPartnerName = "CXMLPartnerVerifier2";
private final static String toRole = "Supplier";
private final static String expectedURL = "http://xyz/abc?from=" + myTradingPartnerName;
private DocSerializer ds;

// このアプリケーションのトークンを作成
private static CXMLToken token;

// マネージャインスタンスを取得
private static CXMLManager cxmlm = CXMLManager.getInstance();

private static Properties prop = new Properties();

public void init(ServletConfig sc) {
try {
debug("Initializing servlet for Partner1");

// コラボレーションアグリーメントを検索するためのプロパティを設定
prop.setProperty("BusinessProcess", businessProcess);
prop.setProperty("BusinessProcessVersion", businessProcessVersion);
prop.setProperty("DeliveryChannel", deliveryChannel);
prop.setProperty("thisTradingPartner", myTradingPartnerName);
prop.setProperty("otherTradingPartner", otherTradingPartnerName);
prop.setProperty("toRole", toRole);
prop.setProperty("Party", "duns4");

// プロパティを使用してバイヤをマネージャに登録
token = cxmlm.register(prop);

} catch (Exception e) {
debug("CXMLPartnerVerifier1 init exception: " + e);
e.printStackTrace();
}
}

private org.w3c.dom.Document getBusinessDocument() {
DOMImplementationImpl domi = new DOMImplementationImpl();

DocumentType dType =
domi.createDocumentType("request", null, "cXML.dtd");

org.w3c.dom.Document punchoutDoc = new DocumentImpl(dType);
CxmlElementFactory cf = new CxmlElementFactory(punchoutDoc);

try {
String otherSharedSecret = cxmlm.getSharedSecret(otherTradingPartnerName);
debug("Stored Shared Secret for " + otherTradingPartnerName + ": " + otherSharedSecret);

// ヘッダ
Element request = punchoutDoc.createElement("Request");
Element trans = punchoutDoc.createElement("PunchoutSetupRequest");
request.appendChild(trans);

punchoutDoc.appendChild(
cf.createCxmlElement(
// ペイロード
"1233444-200@ariba.acme.com",

// ヘッダ
cf.createHeaderElement(
// 送信元
cf.createFromElement(
cf.createCredentialElement(
"DUNS",

myTradingPartnerName,
null)),
// 送信先
cf.createToElement(
cf.createCredentialElement(
"DUNS",
otherTradingPartnerName,
null)),
// 送信者
cf.createSenderElement(
cf.createCredentialElement(
"AribaNetworkUserId",
"admin@acme.com",
otherSharedSecret),
"Ariba ORMS 5.1P4")),
// 要求
request));

}
catch( Exception e ) {
debug("MessageDeliveryException: " + e.toString());
e.printStackTrace();
}
return punchoutDoc;
}

/**
* The actual work is done in this routine. Construct a message document,
* publish the message, wait for a reply, terminate and report back.
*/
public void service(HttpServletRequest req, HttpServletResponse res)
throws ServletException, IOException
{
try {

// クライアントへの応答表示用のセットアップ
res.setContentType("text/html");
PrintWriter pw = res.getWriter();
pw.println("<HTML><BODY BGCOLOR=#ff0000>");
pw.println("<IMG SRC=logo.jpg WIDTH=185 HEIGHT=156"+
" ALIGN=TOP BORDER=0 NATURALSIZEFLAG=3>");
pw.println("Partner1 process flow: ");
pw.println("Starting Partner1...");

debug("Starting Partner1: get Document...");

CXMLMessage cmsg = new CXMLMessage();

org.w3c.dom.Document reqXMLDoc = getBusinessDocument();

CXMLDocument reqMsgDoc = new CXMLDocument();
reqMsgDoc.setDocument(reqXMLDoc);
cmsg.setRequestDocument(reqMsgDoc);

DocSerializer ds = new DocSerializer();

debug("buyer: request document:\n" +
ds.docToString(reqXMLDoc, true) + "\n");

// プロパティで CA を設定
cmsg.setCollaborationAgreement(prop);

// メッセージを送信して応答を取得
CXMLMessageToken sendToken = (CXMLMessageToken) cmsg.send();
CXMLDocument replyMsgDoc = cmsg.getReplyDocument();

debug("Got document");
if (replyMsgDoc == null) {
debug("replyMsgDoc bad");
}
org.w3c.dom.Document replyXMLDoc = replyMsgDoc.getDocument();

debug("buyer: reply document:\n" +
ds.docToString(replyXMLDoc, true) + "\n");

// 適切な応答の取得を検証
String punchoutURL = replyMsgDoc.getNodeValue(
"//cXML/Response/PunchoutSetupResponse/StartPage/URL");
if (punchoutURL.equals(expectedURL)) {
debug("Correct response received");
pw.println("Correct response received");
}
else {
debug("Unexpected response received");
pw.println("Unexpected response received");
}

// 共有秘密が自分のものであることを検証
String dss = replyMsgDoc.getSenderSharedSecret();
debug("Document Shared Secret for " + myTradingPartnerName + ": " + dss);

String sss = cxmlm.getSharedSecret(myTradingPartnerName);
debug("Stored Shared Secret for " + myTradingPartnerName + ": " + sss);

if (dss.equals(sss)) {
debug("Shared Secret match");
pw.println("Shared Secret match");
} else {

debug("Shared Secret mismatch");
pw.println("Shared Secret mismatch");
}
}
catch( Exception e ) {
debug("MessageDeliveryException: " + e.toString());
e.printStackTrace();
}
}

/**
* A simple routine that writes to the wlc log
*/
private static void debug(String msg){
if (DEBUG)
UserLog.log("***Partner1Servlet: " + msg);
}
}

/*
* Copyright (c) 20001 BEA
* All rights reserved
*/
package examples.ibcxmlverifier;

import java.io.*;
import java.util.*;

import javax.servlet.*;
import javax.servlet.http.*;

import org.w3c.dom.*;
import org.apache.html.dom.*;
import org.apache.xml.serialize.*;
import org.apache.xerces.dom.*;

import com.bea.b2b.protocol.messaging.*;
import com.bea.b2b.protocol.cxml.messaging.*;
import com.bea.b2b.protocol.cxml.CXMLListener;
import com.bea.b2b.protocol.cxml.*;

import com.bea.eci.logging.*;

/**
* This example provides a simple test that will verify message flow of cXML
* peer-to-peer sending and receiving a cXML document.
* The two peers (Partner1 and Partner2) are running on a single WLS.
* Partner1 sends a PunchoutRequest to Partner2. Partner2 generates a
* PunchoutSetupResponse and returns it to Partner1. Shared Secrets are verified
* at both ends.
*/
public class Partner2Servlet extends HttpServlet {

static final boolean DEBUG = true;

private final static String businessProcess = "PunchoutSetup";
private final static String businessProcessVersion = "1.1.009";
private final static String deliveryChannel = "CXMLPartnerVerifier2";
private final static String myTradingPartnerName = "CXMLPartnerVerifier2";
private final static String otherTradingPartnerName = "CXMLPartnerVerifier1";
private final static String toRole = "Buyer";

// このアプリケーションのトークンを作成
private static CXMLToken token;

// マネージャインスタンスを取得
private static CXMLManager cxmlm = CXMLManager.getInstance();

private static Properties prop = new Properties();

public void init(ServletConfig sc) {
try {
debug("Initializing servlet for Partner2");

// コラボレーションアグリーメントを検索するためのプロパティを設定
prop.setProperty("BusinessProcess", businessProcess);
prop.setProperty("BusinessProcessVersion", businessProcessVersion);
prop.setProperty("DeliveryChannel", deliveryChannel);
prop.setProperty("thisTradingPartner", myTradingPartnerName);
prop.setProperty("otherTradingPartner", otherTradingPartnerName);
prop.setProperty("toRole", toRole);
prop.setProperty("Party", "duns5");

// プロパティを使用してサプライヤリスナをマネージャに登録
token = cxmlm.register(new Partner2MessageListener(), prop);

debug("Partner2 waiting for message...");
} catch (Exception e) {
debug("CXMLPartnerVerifier2 init exception: " + e);
e.printStackTrace();
}
}

/**
* This routine starts the peer
*/
public void service(HttpServletRequest req, HttpServletResponse res)
throws ServletException, IOException{
debug("Starting Partner2");
}

/**
* A simple routine that writes to the wls log
*/
private static void debug(String msg){
if (DEBUG)
UserLog.log("***Partner2Servlet: " + msg);
}

public class Partner2MessageListener
implements CXMLListener

{
public void onMessage(CXMLMessage cmsg) {
XPathHelper xp = new XPathHelper();

try {
debug("Partner2 received message");
// QualityOfService qos = cmsg.getQoS();

CXMLDocument reqMsgDoc = cmsg.getRequestDocument();
if (reqMsgDoc == null){
throw new Exception("Did not get a request payload");
}
Document reqXMLDoc = reqMsgDoc.getDocument();
if (reqXMLDoc == null){
throw new Exception("Did not get a request document");
}
String from = reqMsgDoc.getNodeValue(
"//cXML/Header/From/Credential/Identity" );
if (from == null) {
from = "nobody";
}
debug("Received request from " + from );

DocSerializer ds = new DocSerializer();

debug("supplier: request document:\n" +
ds.docToString(reqXMLDoc, true) + "\n");

debug("Building reply document");

DOMImplementationImpl domi = new DOMImplementationImpl();
DocumentType dType =
domi.createDocumentType("response", null, "cXML.dtd");

org.w3c.dom.Document replyXMLDoc = new DocumentImpl(dType);
CxmlElementFactory cf = new CxmlElementFactory( replyXMLDoc );

String otherSharedSecret = cxmlm.getSharedSecret(otherTradingPartnerName);
debug("Stored Shared Secret for " + otherTradingPartnerName + ": " + otherSharedSecret);

replyXMLDoc.appendChild(
cf.createCxmlElement(
// ペイロード
"1233444-200@ariba.acme.com",

// ヘッダ
cf.createHeaderElement(
// 送信元

cf.createFromElement(
cf.createCredentialElement(
"DUNS",
myTradingPartnerName,
null)),
// 送信先
cf.createToElement(
cf.createCredentialElement(
"DUNS",
otherTradingPartnerName,
null)),
// 送信者
cf.createSenderElement(
cf.createCredentialElement(
"AribaNetworkUserId",
"admin@acme.com",
otherSharedSecret),
"Ariba ORMS 5.1P4")),
// 本文
cf.createResponseElement(
"200",
"ok",
cf.createPunchoutSetupResponseElement(
"http://xyz/abc?from=" + from ))));

CXMLDocument replyMsgDoc = new CXMLDocument();
replyMsgDoc.setDocument(replyXMLDoc);

cmsg.setReplyDocument(replyMsgDoc);

debug("supplier: reply document:\n" +
ds.docToString(replyXMLDoc, true) + "\n");

// 共有秘密が自分のものであることを検証
String dss = reqMsgDoc.getSenderSharedSecret();
debug("Document Shared Secret for " + myTradingPartnerName + ": " + dss);

String sss = cxmlm.getSharedSecret(myTradingPartnerName);
debug("Stored Shared Secret for " + myTradingPartnerName + ": " + sss);

if (dss.equals(sss)) {
debug("Shared Secret match");
} else {
debug("Shared Secret mismatch");
}

// プロパティで CA を設定
cmsg.setCollaborationAgreement(prop);
cmsg.reply();

debug("Partner2 sent reply");
} catch(Exception e) {
debug("Exception errors" + e);
e.printStackTrace();
}
}

public void onTerminate(Message msg) throws Exception {
debug(" received terminate notification for " + msg.getConversationId());

// マネージャから登録を解除
cxmlm.deregister(prop);
}
}
}