BPEL 프로세스의 다이내믹 생성
저자 Jerry Thomas

XQuery를 통해 데이터베이스에 저장된 매개변수를 BPEL XML 정의로 변환하고 BPEL 프로세스를 다이내믹하게 생성하는 방법을 설명합니다.

전체 BPEL Cookbook 시리즈 목록 보기

아티클 관련 다운로드: 샘플 코드 Oracle BPEL Process Manager and Designer Saxon XSLT and XQuery Parser

게시일: 2005년 11월

이 시리즈의 제 3부에서는, 엔드 포인트 레퍼런스(end point reference)를 통해 파트너 링크를 처리함으로써 BPEL 프로세스를 다이내믹하게 생성하는 방법에 대해 알아 보았습니다. 이러한 방법은 파트너와의 관계에 변화가 발생하더라도, 이에 무관하게 프로세스를 구축할 수 있다는 장점이 있습니다. 하지만, 파트너 링크 이외의 다른 변수들을 다이내믹하게 변경해 주어야 하는 상황이 있을 수도 있습니다.

• 각 비즈니스 부서 별로 얼마나 많은 공간을 사용하고 있는가?
  비즈니스 부서들이 공간을 효율적으로 공유하려면 어떻게 해야 하는가?
• 부동산 임대가 언제 만료되는가? 기업의 성장 곡선을 감안할 때, 재협상 시 임대 비용은 얼마 정도가 적정한가?
• 비즈니스 부서를 다른 층, 또는 다른 건물로 이전하는 경우 최적의 계획은 무엇인가?

그림 1 비즈니스 프로세스 라이프사이클

다이내믹하게 “on-the-fly” 프로세스를 생성하기 위해서는 여러 단계의 작업이 필요합니다. 먼저 애널리스트는 커스텀 디자이너를 이용하여 비즈니스 프로세스를 비주얼하게 모델링합니다.

1. 프로세스 정의는 커스텀 디자이너에 의해 데이터베이스에 저장됩니다.
2. BPEL Generator는 프로세스 정의를 읽고 검증합니다. 그런 다음 데이터베이스에 저장된 데이터를 이용하여 BPEL XML 파일과 기타 필요한 파일을 생성합니다.
3. BPEL 프로세스는 Oracle BPEL Process Manager Server에 다이내믹하게 deploy됩니다.

1. 사무실의 큐브(cube)가 빈 경우 비즈니스 프로세스를 시작합니다 (해당 큐브의 EmployeeCount가 0으로 설정됩니다).
2. 3 개월 간 유예 기간을 둡니다 (EmployeeCount가 0 보다 높은 값으로 재설정되는 경우 플로우를 종료합니다).
3. 자산 관리자에게 이메일을 전송하여, 해당 공간이 더 이상 기존의 비즈니스 부서에 할당되어 있지 않음을 통보합니다.
4. 해당 공간의 데이터를 업데이트하여, 기존 비즈니스 부서에 할당된 내역을 해제합니다.

그림 2 커스텀 프로세스 디자이너의 Cube Management 비즈니스 프로세스

앞에서 설명한 것처럼, Oracle BPEL Process Manager 엔진은 써드 파티 디자이너/툴과의 통합 기능을 제공합니다. 또 써드 파티 디자이너/툴을 이용하여 BPEL 파일을 다이내믹하게 생성할 수 있습니다.

그림 3 Cube Management 프로세스 정의의 저장을 위한 단순화된 데이터 스키마

The WorkflowProcess 오브젝트는 프로세스 설계 내용을 저장하는데 사용됩니다. 이 오브젝트에 포함된 매개변수와 노드는 프로세스의 시퀀스와 액티비티 타입을 정의합니다. 디자이너가 지원하는 프로세스 액티비티 타입에 따라 각각 다른 WorkflowNode 오브젝트가 사용됩니다. 이 오브젝트가 BPEL 컨스트럭트가 아니며, 하나 이상의 BPEL 액티비티에 매핑되는 커스텀 컨스트럭트임을 참고하시기 바랍니다. 커스텀 디자이너를 통해 deploy 작업이 이루어지고 나면 CubeManagement 프로세스의 상세 정보는 아래와 같이 데이터베이스에 저장됩니다.

BPEL Generator는 이 테이블을 읽어 들여 BPEL 파일을 다이내믹하게 생성하기 위해 사용합니다. 아래 섹션은 이 프로세스를 설명하고 있습니다.

1. 데이터베이스 노드의 조회.
BPEL 생성 과정은 Java 코드를 통해 구현됩니다. Java 코드를 이용해 각 워크플로우 프로세스를 위한 WorkflowNode를 읽어 들이고, 처리되어야 하는 모든 노드의 목록을 생성합니다.
2. 각 노드를 위한 BPEL 액티비티의 생성.
목록에 포함된 각 워크플로우 노드로부터 <scope/> 액티비티 태그가 적용된 BPEL 액티비티가 생성됩니다. BPEL 액티비티의 처리 과정에서 BPEL 매개변수가 필요한 경우, 해당 매개변수는 해당 시점의 스코프에서만 확인이 가능합니다 (따라서 변수명 충돌과 같은 문제를 예방할 수 있습니다). 각 노드에 대해 XQuery 템플릿을 생성하고 BPEL XML 태그를 생성해야 합니다. XQuery 프로세서는 XQuery 템플릿을 처리하여 BPEL 노드 및 인스턴스 정보를 구성하고, 그 결과를 다시 반환합니다.
3. BPEL 파일의 생성.
호출 프로세스는 각 노드를 위한 BPEL 액티비티를 조합하여, 전체 프로세스를 대표하는 마스터 BPEL 파일을 생성합니다. 또 각각의 WokflowNode를 위한 <scope/> 블록이 생성되어 첨부됩니다.

<process>
	<scope>
		<!— start workflow node related activities -!>
	</scope>
	<scope>
		<!— wait workflow node related activities -!>
	</scope>
	<scope>
		<!— mail workflow node related activities -!>
	</scope>
	<scope>
		<!— update workflow node related activities -!>
	</scope>
</process>

<scope>
	<!-- generation for Message activity -->
	<variables>

	<!-- Define variables input, output and error variables-->
		<variable name="emailRequest" messageType="services:EntityAsyncMsgWSRequestMessage"/>
		<variable name="emailResponse" messageType="services:EntityAsyncMsgWSResultMessage"/>
		<variable name="fault" messageType="services:EntityFaultMessage" />
	</variables>

	<!--Begin the BPEL activities -->
	<sequence>

	<!--This is the first assign activity. It configures the input variable with 
   <!-- identification of node ($nodekey) and function to be called -->
	<!-- by the external webService (bpelSendEmail). -->

		<assign>
			<copy>
				<from>
					<ent:EntityCollectionElem xmlns:ent="http://www.centerstonesoft.com/schema/entity" >
						<ent:Header/>
						<ent:entityName/>
						<ent:EntityElem>
							<ent:entityKey>{ $nodeKey }</ent:entityKey>
							<ent:method >
								<ent:methodName>bpelSendEmail</ent:methodName>
								<ent:parameter>
									<ent:PropName>thread</ent:PropName>
									<ent:Type>string</ent:Type>
									<ent:Value/>
								</ent:parameter>
							</ent:method>
						</ent:EntityElem>
					</ent:EntityCollectionElem>
				</from>
				<to variable="emailRequest" part="payload"/>
			</copy>
		</assign>

	<!--Second and third assign activity configure the input variable -->
	<!--with identification of actual process instance -->

		<assign>
			<copy>
				<from variable="input" part="parameters" query="//ent:Header"/>
				<to variable="emailRequest" part="payload" query="//ent:Header"/>
			</copy>
		</assign>
		<assign>
			<copy>
				<from variable="threadKey" part="value"/>
				<to variable="emailRequest" part="payload" query="//ent:parameter[ent:PropName = 'thread']/ent:Value"/>
			</copy>
		</assign>

		<!--After configuring input variable with node, instance and function to be called, 
		       invoke the external service -->
		<invoke name="invoke" partnerLink="EntityAsyncMsgWSLink" 
		           portType="services:EntityAsyncMsgWS" operation="invoke" inputVariable="emailRequest"/>

		<!--Check response from external service. If response indicates fault, throw exception. -->
		<!--If no response is received for 10 days, throw exception -->
		<pick name="deadlined_receive" >

			<!--Set output variable if return result from external webservice is OK-->
			<onMessage partnerLink="EntityAsyncMsgWSLink" portType="services:EntityAsyncMsgWSCallback" 
			      operation="onResult" variable="emailResponse">
				<empty/>
			</onMessage>

		<!--On fault, check the fault code and throw  appropriate exception-->

			<onMessage operation="onFault" partnerLink="EntityAsyncMsgWSLink" 
			      portType="services:EntityAsyncMsgWSCallback" variable="fault">
				<switch>
					<case condition="bpws:getVariableData('fault', 'value',  
					      '/EntityFault/faultcode') = 'MailException' ">
						<throw faultName="ent:MailException" faultVariable="fault" />
					</case>
					<otherwise>
						<throw faultName="ent:SystemException" faultVariable="fault" />
					</otherwise>
				</switch>
			</onMessage>

			<!--If no response for 10 days, throw  exception-->
			<onAlarm  for="'P10D'">
				<throw faultName="ent:SystemException"/>
			</onAlarm>
		</pick>
	</sequence>
</scope>

/**
 * Recursively generates an activity including any child activities.
 * @param activity the node that is being generated, the value is null for the top-level
 * process node
 * @return typically the root element of the generated XML document
 * @throws EntityException
 */
    protected String generateActivity(WorkflowNode activity) throws EntityException
    {
	//Find the next node in the list to be processed
        BpelActivityType activityType = getBpeBpelActivityType(activity);
	//Get the parameters to be passed to node
        HashMap params = calculateParameters(activity, activityType);
        try {
            //Get corresponding XQuery file for the node
            XQuery q = XQuery.newXQueryFromResource("bpelgen/" + activityType.getQuery());
            //Call the Saxon XQuery Processor to run the query. 
            XQueryResult result = q.run(null, params, null);
            //Convert the result into a string 
            String parentXml = result.serializeString();
            if (logger.isDebugEnabled()) {
                logger.debug("Generated for parent '" + activityType.getName() + "' is \n" + parentXml);
            }
            //If there are child nodes, recursively invoke generate activity
            if (_process.hasChildren(activity)) {
                //Call java relational class
                Iterator it = _process.getChildrenIterator(activity);
                //Recursively call generateActivity for child nodes. For ‘Cube Management Process’, these will be 
	//start, wait, message, update & end
                while (it.hasNext()) {
                    WorkflowNode childActivity = (WorkflowNode) it.next();
                    String childXml = generateActivity(childActivity);
                    // now use Saxon XSLT to add the document generated for the children to the result document
	// Get the Transformer used for this transformation
                    Transformer transformer = getPrependTransformer();
                    transformer.setParameter("inserted", DomUtils.getDocument(new ByteArrayInputStream(childXml.getBytes())));
                    StreamResult saveResult = new StreamResult(new ByteArrayOutputStream());
                    try {
                        StreamSource src = new StreamSource(new ByteArrayInputStream(parentXml.getBytes()));
	   // Transform the XML Source
                        transformer.transform(src, saveResult);
                    }
                    finally {
                        transformer.clearParameters();
                    }
                    parentXml = ((ByteArrayOutputStream)saveResult.getOutputStream()).toString();
                    if (logger.isDebugEnabled()) {
                        BpelActivityType childType = getBpeBpelActivityType(childActivity);
                        logger.debug("Preprocessed for parent '" + activityType.getName() + "' and child '" +
                                     childType.getName() + "' is \n" + parentXml);
                    }
                }
            }
            // remove the <insert-here> node
            Transformer transformer = getRemovePrependTransformer();
            StreamResult saveResult = new StreamResult(new ByteArrayOutputStream());
            StreamSource src = new StreamSource(new ByteArrayInputStream(parentXml.getBytes()));
            transformer.transform(src, saveResult);
            parentXml = ((ByteArrayOutputStream)saveResult.getOutputStream()).toString();
            if (logger.isDebugEnabled()) {
                logger.debug("Generated for '"+activityType.getName()+"' is \n" + parentXml);
            }
            return parentXml;
        }
        catch (SAXException ex) {
            throw new EntityException("Failed to run transform "+activityType.getQuery(), ex);
        }
        catch (TransformerException ex) {
            throw new EntityException("Failed to run transform "+activityType.getQuery(), ex);
        }
        catch (IOException ex) {
            throw new EntityException("Failed to load query "+activityType.getQuery(), ex);
        }
    }

<?xml version="1.0" encoding="UTF-8"?>
<project default="main" basedir="C:/DOCUME~1/jerry/LOCALS~1/Temp/cs_bpelgen_simple24369" name="BpelDeploy">
   <target name="main">
      <bpelc keepGenerated="true" deploy="jt_dev" rev="1.0" home="c:\orabpel"/>
   </target>
</project>

String args[] = new String[1];
args[0] = "c:/orabpelpm/integration/orabpel/bin/obant.bat";
            
Execute exe = new Execute();
exe.setCommandline(args);
exe.setWorkingDirectory(_deploydir);
int retval = exe.execute();
if ( retval != 0 ) {
    throw new ExecuteException("process failed to deploy");