jp.go.nict.langrid.custominvoke.workflowsupport

Class AbstractCustomInvokeService

java.lang.Object

jp.go.nict.langrid.servicecontainer.service.AbstractService

jp.go.nict.langrid.wrapper.ws_1_2.AbstractService

jp.go.nict.langrid.custominvoke.workflowsupport.AbstractCustomInvokeService

All Implemented Interfaces:

org.activebpel.rt.IAePolicyConstants, org.activebpel.wsio.invoke.IAeInvokeHandler

Direct Known Subclasses:

ConstructSourceAndMorphemesAndCodes, ReplacementTerm, TemporalBilingualDictionaryWithLongestMatchSearch

public abstract class AbstractCustomInvokeService
extends AbstractService
implements org.activebpel.wsio.invoke.IAeInvokeHandler, org.activebpel.rt.IAePolicyConstants

Field Summary

Fields

Modifier and Type	Field and Description
protected static SimpleDateFormat	DATE_FORMAT

Fields inherited from class jp.go.nict.langrid.wrapper.ws_1_2.AbstractService

ALL_MATCHINGMETHODS, EMPTY_LANGUAGEPAIRS, EMPTY_LANGUAGEPATHS, EMPTY_LANGUAGES, MINIMUM_MATCHINGMETHODS

Fields inherited from interface org.activebpel.rt.IAePolicyConstants

ABPEL_RETRY_CHECK_NS, ADDUTELEMENT, AE_CONTEXT_MAPPED_PROPERTIES, ANONYMOUS_PRINCIPAL, ATTR_HTTP_CLIENT_CONNECTION_TIMEOUT, ATTR_HTTP_CONNECTION_MANAGER_TIMEOUT, ATTR_HTTP_REDIRECT_WITH_GET, ATTR_HTTP_SOCKET_TIMEOUT, ATTR_HTTP_TCP_NODELAY, ATTR_JMS_CORRELATION_ID, ATTR_JMS_EXPIRATION, ATTR_JMS_MANAGER_ID, ATTR_JMS_MESSAGE_FORMAT, ATTR_JMS_MESSAGE_TYPE, ATTR_JMS_PRIORITY, ATTR_SUSPEND_PROCESS, CONVERSATION_ID_HEADER, CRYPTO_PROPERTIES, DEFAULT_USER, DIRECTION_BOTH, DIRECTION_IN, DIRECTION_OUT, DIRECTREFERENCE, ENCRYPTION_ACTION, FAULT_EXCLUSION_LIST_ATTR, FAULT_LIST_ATTR, INTERVAL_TAG, ISSUER_SERIAL, JMS_BYTES_MESSAGE, JMS_SOAP_FORMAT, JMS_TEXT_MESSAGE, JMS_XML_FORMAT, PARAM_DELEGATE_CLASS, PARAM_HANDLER_CLASS, PARAM_RECEIVE_HANDLER, PARAM_STYLE, PARAM_TRANSPORT, PARAM_USE, PRINCIPAL_HEADER, PROCESS_SERVICE_NAME_ATTR, QNAME_WILDCARD, RECEIVER_ACTION, RETRY_ATTEMPTS_ATTR, RETRY_CHECK_INPUT_TAG, RETRY_CHECK_OUTPUT_PART, RETRY_CHECK_PROCESS_ID_TAG, RETRY_FAULT_ON_FAILURE, RETRY_INTERVAL_ATTR, RETRY_ON_FAILURE_ATTR, RETRY_POLICY_TAG, RETRY_SUSPEND_ON_FAILURE, RETRY_TAG, RM_TRANS_ID, RM_TRANSPORT, SAML_AUTH_METHOD, SAML_CONFIRM_HOLDER_OF_KEY, SAML_CONFIRM_METHOD, SAML_CONFIRM_SENDER_VOUCHES, SAML_SUBJECT_NAME, SECURITY_ACTION, SIGNATURE_ACTION, SIGNATURE_USER, TAG_ALIAS_ATTR, TAG_ASSERT_ACK_INTERVAL, TAG_ASSERT_AUTH_NONCE, TAG_ASSERT_AUTH_PASSWORD, TAG_ASSERT_AUTH_PREEMPTIVE, TAG_ASSERT_AUTH_PWD_CLEARTEXT, TAG_ASSERT_AUTH_PWD_DIGEST, TAG_ASSERT_AUTH_PWD_TEXT, TAG_ASSERT_AUTH_SAML, TAG_ASSERT_AUTH_USER, TAG_ASSERT_AUTH_USERNAMETOKEN, TAG_ASSERT_EXP_BACKOFF, TAG_ASSERT_MANAGED_CORRELATION, TAG_ASSERT_MAP_PROCESS_INTIATOR, TAG_ASSERT_MILLIS, TAG_ASSERT_RM, TAG_ASSERT_RM_ACKTO, TAG_ASSERT_RM_BINDING, TAG_ASSERT_RM_PROXY, TAG_ASSERT_RM_RETRY_INTERVAL, TAG_ASSERT_RM_TIMEOUT, TAG_ASSERT_SECURITY_AUTH, TAG_ASSERT_SECURITY_ENCRYPT, TAG_ASSERT_SECURITY_SIGN, TAG_ASSERT_TIMESTAMP, TAG_ASSERT_XPATH_RECEIVE, TAG_ASSERT_XPATH_SEND, TAG_DESCRIPTION_ATTR, TAG_DIRECTION_ATTR, TAG_HTTP_MIME_TYPE, TAG_HTTP_TRANSPORT_OPTIONS, TAG_HTTP_XML_TYPES, TAG_INVOKE_RECOVERY, TAG_JMS_DELIVERY, TAG_NAME_ATTR, TAG_NAMESPACE_ATTR, TAG_REST_ENABLED, TAG_REST_USAGE, TAG_TYPE_ATTR, TAG_VALUE_ATTR, X509KEYIDENTIFIER, XMLNS_PREFIX, XPATH_MAP, XPATH_PREFIX, XPATH_QUERY_PARAMS, XPATH_QUERY_SOURCE, XPATH_QUERY_SOURCE_CONTEXT, XPATH_QUERY_SOURCE_OPTIONS

Constructor Summary

Constructors

Constructor and Description
AbstractCustomInvokeService()

Method Summary

Methods

Modifier and Type	Method and Description
protected org.apache.axis.client.Call	createCall(javax.wsdl.Service aWsdlService, javax.wsdl.Operation aOperation, org.activebpel.wsio.IAeWebServiceEndpointReference aEndpoint, org.activebpel.rt.bpel.server.engine.invoke.AeAddressHandlingType aAddressHandlingType, org.activebpel.wsio.IAeWebServiceEndpointReference aDefaultReplyTo) Create and configure the client call object.
protected org.activebpel.rt.axis.bpel.invokers.AeAxisInvokeContext	createInvokeContext(org.activebpel.wsio.invoke.IAeInvoke aInvoke, javax.wsdl.Operation aOperation, org.activebpel.wsio.invoke.AeInvokeResponse aResponse, org.apache.axis.client.Call aCall) Create the invoke context.
protected org.activebpel.wsio.AeWebServiceMessageData	createOutputMessageData(org.activebpel.rt.axis.bpel.invokers.AeAxisInvokeContext aContext) Creates the container for the response or null if it's a one-way
protected org.activebpel.wsio.AeWebServiceMessageData	extractMessageData(javax.wsdl.Fault aWsdlFault, Element aFirstDetailElement) Extracts the message data from an AxisFault's fault details.
protected javax.wsdl.Fault	findMatchingWsdlFault(Element aFaultDetailElement, Collection aDefinedFaultsForOperationColl) Attempts to match the element to one of the declared faults for the operation invoked.
protected javax.wsdl.BindingOperation	getBindingOperation(javax.wsdl.Service aWsdlService, String aOperationName, org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef) Get the BindingOperation from the service object.
protected String	getEndpointUrl(javax.wsdl.Service aWsdlService, org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef, org.activebpel.rt.bpel.server.engine.invoke.AeAddressHandlingType aAddressHandlingType) Extract the endpoint url string from the service.
protected String	getErrorDetail(org.apache.axis.AxisFault aFault) Converts the Element[] in Axis's faultDetail to a String for as the error detail string in our response.
protected Map	getPolicyDrivenProperties(List aPolicyList) Get policy driven call properties.
protected abstract javax.wsdl.Port	getPort(javax.wsdl.Service service)
protected javax.wsdl.PortType	getPortType(javax.wsdl.Service aWsdlService, org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef, org.activebpel.wsio.invoke.IAeInvoke aInvoker) Get the PortType that we're invoking.
String	getPortTypeName() _portTypeを返す。
protected org.apache.axis.constants.Style	getRequestStyle(javax.wsdl.Service aWsdlService, String aOperationName, org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef) Determine the call style (RPC or Document).
protected javax.wsdl.Service	getServiceObject(org.activebpel.wsio.invoke.IAeInvoke aInvoke, org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef) Find the matching javax.wsdl.Service service object.
protected String	getSoapAction(javax.wsdl.Service aWsdlService, String aOperationName, org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef) Look for the value of a soapAction attribute.
org.activebpel.wsio.IAeWebServiceResponse	handleInvoke(org.activebpel.wsio.invoke.IAeInvoke invokeRequest, String queryData)
protected abstract org.activebpel.wsio.IAeWebServiceResponse	invoke(org.activebpel.wsio.invoke.IAeInvoke invokeRequest, String queryData, QName qName)
protected boolean	isMatch(boolean aTypeFlag, QName aType, javax.wsdl.Part aPart) Determines if the part we're inspecting matches the type that we found in the fault details.
protected boolean	isSimpleType(Element aElement) Helper method that checks to see if the passed elements data is a simple type or complex type.
protected javax.wsdl.Fault	resolveToWsdlFault(String aNamespaceUri, javax.wsdl.Operation aOperation, QName aFaultCode, Element aFirstDetailElement) Attempts to resolve the AxisFault to a fault defined for the operation being invoked.
protected void	setCredentialsOnCall(org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointReference, org.apache.axis.client.Call aCall) Extracts the credentials (if any) from the endpoint reference and sets them on the call object.
protected void	setFaultOnResponse(String aPortTypeNamespace, javax.wsdl.Operation aOper, org.apache.axis.AxisFault aAxisFault, org.activebpel.wsio.invoke.AeInvokeResponse aResponse) Sets the fault data on the response.
void	setPortTypeName(String type) _portTypeを設定する。
protected void	setupCallForPolicies(List aPolicyList, org.apache.axis.client.Call aCall) Call setup for policy assertions.
protected org.activebpel.wsio.IAeWebServiceEndpointReference	updateReplyToEndpoint(org.activebpel.wsio.invoke.IAeInvoke aInvoke) Extract the wsa:ReplyTo IAeWebServiceEndpointReference from the IAeInvoke object and see if we need to include engine managed correlation headers.

Methods inherited from class jp.go.nict.langrid.wrapper.ws_1_2.AbstractService

acquireSemaphore, checkStartupException, convertLanguagePairs, convertLanguages, doGetLastUpdate, getCurrentServiceContext, getDoDoubleSearch, getEliminateDuplicates, getInitParameter, getInitParameterBoolean, getInitParameterInt, getInitParameterLong, getInitParameters, getInitParameterString, getInitParameterUsingTransformer, getLastUpdate, getLogListener, getMaxResults, getMaxWaitMillisForExternalProcess, getRequestMimeHeaders, getServiceContext, getWorkDirectory, getWorkFile, log, parseDateMacro, processEnd, processEnd, processLap, processStart, releaseSemaphore, setCurrentServiceContext, setDoubleSearchResults, setEliminateDuplicates, setLogListener, setMaxResults, setMaxThreads, setMaxWaitMillisForExternalProcess, setMaxWaitMillisForThread, setMeasureProcessTime, setProcessTimeWarningThreasholdMillis, setStartupException

Methods inherited from class jp.go.nict.langrid.servicecontainer.service.AbstractService

getComponentServiceFactory, getFile, getServiceName, setComponentServiceFactory, setServiceName

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DATE_FORMAT

protected static final SimpleDateFormat DATE_FORMAT

Constructor Detail

AbstractCustomInvokeService

public AbstractCustomInvokeService()

Method Detail

handleInvoke

public org.activebpel.wsio.IAeWebServiceResponse handleInvoke(org.activebpel.wsio.invoke.IAeInvoke invokeRequest,
                                                     String queryData)

Specified by:

handleInvoke in interface org.activebpel.wsio.invoke.IAeInvokeHandler

invoke

protected abstract org.activebpel.wsio.IAeWebServiceResponse invoke(org.activebpel.wsio.invoke.IAeInvoke invokeRequest,
                                               String queryData,
                                               QName qName)

updateReplyToEndpoint

protected org.activebpel.wsio.IAeWebServiceEndpointReference updateReplyToEndpoint(org.activebpel.wsio.invoke.IAeInvoke aInvoke)
                                                                            throws org.activebpel.rt.bpel.AeBusinessProcessException

Extract the wsa:ReplyTo IAeWebServiceEndpointReference from the IAeInvoke object and see if we need to include engine managed correlation headers.

Parameters:

aInvoke -

Throws:

org.activebpel.rt.bpel.AeBusinessProcessException

getServiceObject

protected javax.wsdl.Service getServiceObject(org.activebpel.wsio.invoke.IAeInvoke aInvoke,
                                  org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef)
                                       throws org.activebpel.rt.bpel.AeBusinessProcessException

Find the matching javax.wsdl.Service service object.

Parameters:

aInvoke -

aEndpointRef -

Throws:

org.activebpel.rt.bpel.AeBusinessProcessException

createCall

protected org.apache.axis.client.Call createCall(javax.wsdl.Service aWsdlService,
                                     javax.wsdl.Operation aOperation,
                                     org.activebpel.wsio.IAeWebServiceEndpointReference aEndpoint,
                                     org.activebpel.rt.bpel.server.engine.invoke.AeAddressHandlingType aAddressHandlingType,
                                     org.activebpel.wsio.IAeWebServiceEndpointReference aDefaultReplyTo)
                                          throws Exception

Create and configure the client call object.

Parameters:

aWsdlService -

aOperation -

aEndpoint -

Throws:

Exception

getEndpointUrl

protected String getEndpointUrl(javax.wsdl.Service aWsdlService,
                    org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef,
                    org.activebpel.rt.bpel.server.engine.invoke.AeAddressHandlingType aAddressHandlingType)
                         throws org.activebpel.rt.bpel.AeBusinessProcessException

Extract the endpoint url string from the service.

Parameters:

aWsdlService -

aEndpointRef -

aAddressHandlingType -

Throws:

org.activebpel.rt.bpel.AeBusinessProcessException

getRequestStyle

protected org.apache.axis.constants.Style getRequestStyle(javax.wsdl.Service aWsdlService,
                                              String aOperationName,
                                              org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef)
                                                   throws org.activebpel.rt.bpel.AeBusinessProcessException

Determine the call style (RPC or Document).

Parameters:

aWsdlService -

aOperationName -

aEndpointRef -

Throws:

org.activebpel.rt.bpel.AeBusinessProcessException

getSoapAction

protected String getSoapAction(javax.wsdl.Service aWsdlService,
                   String aOperationName,
                   org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef)
                        throws org.activebpel.rt.bpel.AeBusinessProcessException

Look for the value of a soapAction attribute. If no action is explicitly defined in wsdl, returns the implicit action based on the service namespace and operation name since WS-Addressing mandates the use of a wsa:Action header

Parameters:

aWsdlService -

aOperationName -

aEndpointRef -

Throws:

org.activebpel.rt.bpel.AeBusinessProcessException

getBindingOperation

protected javax.wsdl.BindingOperation getBindingOperation(javax.wsdl.Service aWsdlService,
                                              String aOperationName,
                                              org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef)
                                                   throws org.activebpel.rt.bpel.AeBusinessProcessException

Get the BindingOperation from the service object.

Parameters:

aWsdlService -

aOperationName -

aEndpointRef -

Throws:

org.activebpel.rt.bpel.AeBusinessProcessException

getPortType

protected javax.wsdl.PortType getPortType(javax.wsdl.Service aWsdlService,
                              org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointRef,
                              org.activebpel.wsio.invoke.IAeInvoke aInvoker)
                                   throws org.activebpel.rt.bpel.AeBusinessProcessException

Get the PortType that we're invoking.

Parameters:

aWsdlService -

aEndpointRef -

aInvoker -

Throws:

org.activebpel.rt.bpel.AeBusinessProcessException

createInvokeContext

protected org.activebpel.rt.axis.bpel.invokers.AeAxisInvokeContext createInvokeContext(org.activebpel.wsio.invoke.IAeInvoke aInvoke,
                                                                           javax.wsdl.Operation aOperation,
                                                                           org.activebpel.wsio.invoke.AeInvokeResponse aResponse,
                                                                           org.apache.axis.client.Call aCall)

Create the invoke context.

Parameters:

aInvoke -

aOperation -

aResponse -

aCall -

setFaultOnResponse

protected void setFaultOnResponse(String aPortTypeNamespace,
                      javax.wsdl.Operation aOper,
                      org.apache.axis.AxisFault aAxisFault,
                      org.activebpel.wsio.invoke.AeInvokeResponse aResponse)

Sets the fault data on the response.

Parameters:

aPortTypeNamespace - namespace of the port type we invoked

aOper - the operation we invoked

aAxisFault - fault generated from invoke

aResponse - response object we're populating

resolveToWsdlFault

protected javax.wsdl.Fault resolveToWsdlFault(String aNamespaceUri,
                                  javax.wsdl.Operation aOperation,
                                  QName aFaultCode,
                                  Element aFirstDetailElement)

Attempts to resolve the AxisFault to a fault defined for the operation being invoked. We first attempt to match the faultcode to a fault name. Failing that, we'll examine the faultdetails to see if we can match the element's type to one of the operation's fault messages.

Parameters:

aNamespaceUri - namespace for the operation, used to identify the fault name

aOperation - wsdl operation invoked

aFaultCode - QName from the faultcode element in the fault

aFirstDetailElement - The first element within the fault details

findMatchingWsdlFault

protected javax.wsdl.Fault findMatchingWsdlFault(Element aFaultDetailElement,
                                     Collection aDefinedFaultsForOperationColl)

Attempts to match the element to one of the declared faults for the operation invoked. WS-I Basic Profile 1.1 requires that fault parts are elements: http://www.ws-i.org/Profiles/BasicProfile-1.1-2004-08-24.html#Bindings_and_Faults The code here is a little flexible in this regard. It'll handle getting a complex type for a fault part if it has an xsi:type attribute. Otherwise, the fault detail element must be a valid schema element or we cannot reliably determine what fault we should map to.

Parameters:

aFaultDetailElement - The first detail element from the soap fault

aDefinedFaultsForOperationColl - Collection of faults defined for the operation invoked.

isMatch

protected boolean isMatch(boolean aTypeFlag,
              QName aType,
              javax.wsdl.Part aPart)

Determines if the part we're inspecting matches the type that we found in the fault details.

Parameters:

aTypeFlag - true if QName we found maps to a type, false if it maps to a schema element.

aType - qname of the type we're looking for

aPart - wsdl part from the fault message

getErrorDetail

protected String getErrorDetail(org.apache.axis.AxisFault aFault)

Converts the Element[] in Axis's faultDetail to a String for as the error detail string in our response.

Parameters:

aFault -

extractMessageData

protected org.activebpel.wsio.AeWebServiceMessageData extractMessageData(javax.wsdl.Fault aWsdlFault,
                                                             Element aFirstDetailElement)

Extracts the message data from an AxisFault's fault details.

Parameters:

aWsdlFault -

aFirstDetailElement -

isSimpleType

protected boolean isSimpleType(Element aElement)

Helper method that checks to see if the passed elements data is a simple type or complex type.

Parameters:

aElement - The element to check the contents of.

setCredentialsOnCall

protected void setCredentialsOnCall(org.activebpel.wsio.IAeWebServiceEndpointReference aEndpointReference,
                        org.apache.axis.client.Call aCall)

Extracts the credentials (if any) from the endpoint reference and sets them on the call object.

Parameters:

aEndpointReference -

aCall -

getPolicyDrivenProperties

protected Map getPolicyDrivenProperties(List aPolicyList)
                                 throws org.activebpel.rt.bpel.AeBusinessProcessException

Get policy driven call properties.

Parameters:

aPolicyList -

Throws:

org.activebpel.rt.bpel.AeBusinessProcessException

setupCallForPolicies

protected void setupCallForPolicies(List aPolicyList,
                        org.apache.axis.client.Call aCall)
                             throws org.activebpel.rt.AeException

Call setup for policy assertions.

Parameters:

aPolicyList -

aCall -

Throws:

org.activebpel.rt.AeException

createOutputMessageData

protected org.activebpel.wsio.AeWebServiceMessageData createOutputMessageData(org.activebpel.rt.axis.bpel.invokers.AeAxisInvokeContext aContext)

Creates the container for the response or null if it's a one-way

Parameters:

aContext -

getPortTypeName

public String getPortTypeName()

_portTypeを返す。

Returns:

_portType

setPortTypeName

public void setPortTypeName(String type)

_portTypeを設定する。

Parameters:

type - _portType

getPort

protected abstract javax.wsdl.Port getPort(javax.wsdl.Service service)