You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by di...@apache.org on 2005/02/20 18:57:02 UTC
svn commit: r154537 [1/6] - in webservices/axis/trunk/java/modules:
core/src/java/org/apache/axis/ core/src/java/org/apache/axis/addressing/
core/src/java/org/apache/axis/addressing/miheaders/
core/src/java/org/apache/axis/addressing/om/
core/src/java/org/apache/axis/clientapi/
core/src/java/org/apache/axis/context/
core/src/java/org/apache/axis/description/
core/src/java/org/apache/axis/engine/ core/src/java/org/apache/axis/handlers/
core/src/java/org/apache/axis/phaseresolver/
core/src/java/org/apache/axis/providers/
core/src/java/org/apache/axis/receivers/
core/src/java/org/apache/axis/transport/
core/src/java/org/apache/axis/transport/http/
core/src/java/org/apache/axis/util/
deployment/src/samples/deployment/service1/org/apache/axis/sample/echo/
samples/src/java/encoding/sample1/
samples/src/java/encoding/sample2/benchMark/
samples/src/java/org/apache/axis/testUtils/
Author: dims
Date: Sun Feb 20 09:56:49 2005
New Revision: 154537
URL: http://svn.apache.org/viewcvs?view=rev&rev=154537
Log:
reformatting, cleanup, spelling, javadocs...no logic changes
Modified:
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/Constants.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/AddressingConstants.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/AnyContentType.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/EndpointReference.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/ServiceName.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/miheaders/RelatesTo.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/om/AddressingHeaders.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/AsyncResult.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Call.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Callback.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Correlator.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Invoker.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/GlobalContext.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/MessageContext.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/SessionContext.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/SimpleSessionContext.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisGlobal.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisModule.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisOperation.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisService.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisTransport.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/DescriptionConstants.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/Flow.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/FlowImpl.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/FlowInclude.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/FlowIncludeImpl.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/HandlerMetadata.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/Parameter.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/ParameterImpl.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/ParameterInclude.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/ParameterIncludeImpl.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/PhaseRule.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/PhasesInclude.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/PhasesIncludeImpl.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/SimpleAxisOperationImpl.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/AxisEngine.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/AxisFault.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/Dispatcher.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/EngineRegistry.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/EngineRegistryFactory.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/EngineRegistryImpl.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/ExecutionChain.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/Handler.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/Phase.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/Provider.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/Receiver.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/ReceiverLocator.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/engine/Sender.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/handlers/AbstractHandler.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/handlers/OpNameFinder.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/phaseresolver/PhaseException.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/phaseresolver/PhaseHolder.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/phaseresolver/PhaseMetadata.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/phaseresolver/PhaseResolver.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/providers/AbstractProvider.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/providers/RawXMLProvider.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/receivers/InOutAsyncReceiver.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/receivers/InOutSyncReceiver.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/transport/AbstractTransportSender.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/transport/TransportReceiver.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/transport/TransportReceiverLocator.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/transport/TransportSender.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/transport/TransportSenderLocator.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/transport/http/AxisServlet.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/transport/http/HTTPConstants.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/transport/http/HTTPTransportReceiver.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/transport/http/HTTPTransportSender.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/transport/http/SimpleHTTPServer.java
webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/util/tcpmon.java
webservices/axis/trunk/java/modules/deployment/src/samples/deployment/service1/org/apache/axis/sample/echo/EchoProvider.java
webservices/axis/trunk/java/modules/samples/src/java/encoding/sample1/EchoProvider.java
webservices/axis/trunk/java/modules/samples/src/java/encoding/sample2/benchMark/BenchProvider.java
webservices/axis/trunk/java/modules/samples/src/java/org/apache/axis/testUtils/SimpleJavaProvider.java
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/Constants.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/Constants.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/Constants.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/Constants.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -15,29 +15,92 @@
*/
package org.apache.axis;
+/**
+ * Class Constants
+ */
public class Constants {
+ /**
+ * Field SOAP_STYLE_RPC_ENCODED
+ */
public static final int SOAP_STYLE_RPC_ENCODED = 1000;
+
+ /**
+ * Field SOAP_STYLE_RPC_LITERAL
+ */
public static final int SOAP_STYLE_RPC_LITERAL = 1001;
+
+ /**
+ * Field SOAP_STYLE_DOC_LITRAL_WRAPPED
+ */
public static final int SOAP_STYLE_DOC_LITRAL_WRAPPED = 1002;
+ /**
+ * Field APPLICATION_SCOPE
+ */
public static final String APPLICATION_SCOPE = "application";
+
+ /**
+ * Field SESSION_SCOPE
+ */
public static final String SESSION_SCOPE = "session";
+
+ /**
+ * Field GLOBAL_SCOPE
+ */
public static final String GLOBAL_SCOPE = "global";
+ /**
+ * Field PHASE_SERVICE
+ */
public static final String PHASE_SERVICE = "service";
+
+ /**
+ * Field PHASE_TRANSPORT
+ */
public static final String PHASE_TRANSPORT = "transport";
+
+ /**
+ * Field PHASE_GLOBAL
+ */
public static final String PHASE_GLOBAL = "global";
+ /**
+ * Field SESSION_CONTEXT_PROPERTY
+ */
public static final String SESSION_CONTEXT_PROPERTY = "SessionContext";
+ /**
+ * Field TRANSPORT_TCP
+ */
public static final String TRANSPORT_TCP = "tcp";
+
+ /**
+ * Field TRANSPORT_HTTP
+ */
public static final String TRANSPORT_HTTP = "http";
+
+ /**
+ * Field TRANSPORT_SMTP
+ */
public static final String TRANSPORT_SMTP = "smtp";
+ /**
+ * Field LISTSERVICES
+ */
public static final String LISTSERVICES = "listServices";
+
+ /**
+ * Field SERVICE_MAP
+ */
public static final String SERVICE_MAP = "servicemap";
+
+ /**
+ * Field SINGLE_SERVICE
+ */
public static final String SINGLE_SERVICE = "singleservice";
+ /**
+ * Field METHOD_NAME_ESCAPE_CHARACTOR
+ */
public static final char METHOD_NAME_ESCAPE_CHARACTOR = '#';
-
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/AddressingConstants.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/AddressingConstants.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/AddressingConstants.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/AddressingConstants.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -15,13 +15,48 @@
*/
package org.apache.axis.addressing;
+/**
+ * Interface AddressingConstants
+ */
public interface AddressingConstants {
+ /**
+ * Field WSA_MESSAGE_ID
+ */
public static final String WSA_MESSAGE_ID = "MessageID";
+
+ /**
+ * Field WSA_RELATES_TO
+ */
public static final String WSA_RELATES_TO = "RelatesTo";
- public static final String WSA_RELATES_TO_RELATIONSHIP_TYPE = "RelationshipType";
+
+ /**
+ * Field WSA_RELATES_TO_RELATIONSHIP_TYPE
+ */
+ public static final String WSA_RELATES_TO_RELATIONSHIP_TYPE =
+ "RelationshipType";
+
+ /**
+ * Field WSA_TO
+ */
public static final String WSA_TO = "To";
+
+ /**
+ * Field WSA_ACTION
+ */
public static final String WSA_ACTION = "Action";
+
+ /**
+ * Field WSA_FROM
+ */
public static final String WSA_FROM = "From";
+
+ /**
+ * Field WSA_REPLY_TO
+ */
public static final String WSA_REPLY_TO = "ReplyTo";
+
+ /**
+ * Field WSA_FAULT_TO
+ */
public static final String WSA_FAULT_TO = "FaultTo";
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/AnyContentType.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/AnyContentType.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/AnyContentType.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/AnyContentType.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -18,18 +18,43 @@
import javax.xml.namespace.QName;
import java.util.HashMap;
+/**
+ * Class AnyContentType
+ */
public class AnyContentType {
+ /**
+ * Field anyContentTypeName
+ */
private String anyContentTypeName;
+
+ /**
+ * Field valueHolder
+ */
private HashMap valueHolder;
+ /**
+ * Constructor AnyContentType
+ */
public AnyContentType() {
valueHolder = new HashMap(5);
}
+ /**
+ * Method addReferenceValue
+ *
+ * @param name
+ * @param value
+ */
public void addReferenceValue(QName name, String value) {
valueHolder.put(name, value);
}
+ /**
+ * Method getReferenceValue
+ *
+ * @param name
+ * @return
+ */
public String getReferenceValue(QName name) {
return (String) valueHolder.get(name);
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/EndpointReference.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/EndpointReference.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/EndpointReference.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/EndpointReference.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -17,6 +17,9 @@
import javax.xml.namespace.QName;
+/**
+ * Class EndpointReference
+ */
public class EndpointReference {
/**
* this can be one of the followings
@@ -26,10 +29,29 @@
*/
private String messageInformationHeaderType;
+ /**
+ * Field address
+ */
private String address;
+
+ /**
+ * Field portType
+ */
private QName portType;
+
+ /**
+ * Field referenceProperties
+ */
private AnyContentType referenceProperties;
+
+ /**
+ * Field referenceParameters
+ */
private AnyContentType referenceParameters;
+
+ /**
+ * Field serviceName
+ */
private ServiceName serviceName;
/**
@@ -39,57 +61,118 @@
* AddressingConstants.WSA_FAULT_TO
* @param address
*/
- public EndpointReference(String messageInformationHeaderType, String address) {
+ public EndpointReference(String messageInformationHeaderType,
+ String address) {
this.messageInformationHeaderType = messageInformationHeaderType;
this.address = address;
}
+ /**
+ * Method getMessageInformationHeaderType
+ *
+ * @return
+ */
public String getMessageInformationHeaderType() {
return messageInformationHeaderType;
}
- public void setMessageInformationHeaderType(String messageInformationHeaderType) {
+ /**
+ * Method setMessageInformationHeaderType
+ *
+ * @param messageInformationHeaderType
+ */
+ public void setMessageInformationHeaderType(
+ String messageInformationHeaderType) {
this.messageInformationHeaderType = messageInformationHeaderType;
}
+ /**
+ * Method getAddress
+ *
+ * @return
+ */
public String getAddress() {
return address;
}
+ /**
+ * Method setAddress
+ *
+ * @param address
+ */
public void setAddress(String address) {
this.address = address;
}
+ /**
+ * Method getPortType
+ *
+ * @return
+ */
public QName getPortType() {
return portType;
}
+ /**
+ * Method setPortType
+ *
+ * @param portType
+ */
public void setPortType(QName portType) {
this.portType = portType;
}
+ /**
+ * Method getReferenceProperties
+ *
+ * @return
+ */
public AnyContentType getReferenceProperties() {
return referenceProperties;
}
+ /**
+ * Method setReferenceProperties
+ *
+ * @param referenceProperties
+ */
public void setReferenceProperties(AnyContentType referenceProperties) {
this.referenceProperties = referenceProperties;
}
+ /**
+ * Method getReferenceParameters
+ *
+ * @return
+ */
public AnyContentType getReferenceParameters() {
return referenceParameters;
}
+ /**
+ * Method setReferenceParameters
+ *
+ * @param referenceParameters
+ */
public void setReferenceParameters(AnyContentType referenceParameters) {
this.referenceParameters = referenceParameters;
}
+ /**
+ * Method getServiceName
+ *
+ * @return
+ */
public ServiceName getServiceName() {
return serviceName;
}
+ /**
+ * Method setServiceName
+ *
+ * @param serviceName
+ */
public void setServiceName(ServiceName serviceName) {
this.serviceName = serviceName;
}
-
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/ServiceName.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/ServiceName.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/ServiceName.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/ServiceName.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -17,8 +17,18 @@
import javax.xml.namespace.QName;
+/**
+ * Class ServiceName
+ */
public class ServiceName {
+ /**
+ * Field name
+ */
private QName name;
+
+ /**
+ * Field portName
+ */
private String portName;
/**
@@ -37,18 +47,38 @@
this.portName = portName;
}
+ /**
+ * Method getName
+ *
+ * @return
+ */
public QName getName() {
return name;
}
+ /**
+ * Method setName
+ *
+ * @param name
+ */
public void setName(QName name) {
this.name = name;
}
+ /**
+ * Method getPortName
+ *
+ * @return
+ */
public String getPortName() {
return portName;
}
+ /**
+ * Method setPortName
+ *
+ * @param portName
+ */
public void setPortName(String portName) {
this.portName = portName;
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/miheaders/RelatesTo.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/miheaders/RelatesTo.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/miheaders/RelatesTo.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/miheaders/RelatesTo.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -15,31 +15,72 @@
*/
package org.apache.axis.addressing.miheaders;
+/**
+ * Class RelatesTo
+ */
public class RelatesTo {
+ /**
+ * Field address
+ */
private String address;
+
+ /**
+ * Field relationshipType
+ */
private String relationshipType = "wsa:Reply";
+ /**
+ * Constructor RelatesTo
+ *
+ * @param address
+ */
public RelatesTo(String address) {
this.address = address;
}
+ /**
+ * Constructor RelatesTo
+ *
+ * @param address
+ * @param relationshipType
+ */
public RelatesTo(String address, String relationshipType) {
this.address = address;
this.relationshipType = relationshipType;
}
+ /**
+ * Method getAddress
+ *
+ * @return
+ */
public String getAddress() {
return address;
}
+ /**
+ * Method setAddress
+ *
+ * @param address
+ */
public void setAddress(String address) {
this.address = address;
}
+ /**
+ * Method getRelationshipType
+ *
+ * @return
+ */
public String getRelationshipType() {
return relationshipType;
}
+ /**
+ * Method setRelationshipType
+ *
+ * @param relationshipType
+ */
public void setRelationshipType(String relationshipType) {
this.relationshipType = relationshipType;
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/om/AddressingHeaders.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/om/AddressingHeaders.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/om/AddressingHeaders.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/addressing/om/AddressingHeaders.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -19,13 +19,43 @@
import org.apache.axis.addressing.miheaders.RelatesTo;
import org.apache.axis.om.SOAPHeader;
+/**
+ * Class AddressingHeaders
+ */
public class AddressingHeaders {
+ /**
+ * Field wsaTo
+ */
private EndpointReference wsaTo;
+
+ /**
+ * Field wsaFrom
+ */
private EndpointReference wsaFrom;
+
+ /**
+ * Field wsaReply
+ */
private EndpointReference wsaReply;
+
+ /**
+ * Field wsaFaultTo
+ */
private EndpointReference wsaFaultTo;
+
+ /**
+ * Field action
+ */
private String action;
+
+ /**
+ * Field messageId
+ */
private String messageId;
+
+ /**
+ * Field relatesTo
+ */
private RelatesTo relatesTo;
/**
@@ -39,69 +69,141 @@
this.action = action;
}
+ /**
+ * Method toOM
+ *
+ * @param soapHeader
+ */
public void toOM(SOAPHeader soapHeader) {
-
}
// ------------------- Setters and Getters --------------------------------------
+
+ /**
+ * Method getWsaTo
+ *
+ * @return
+ */
public EndpointReference getWsaTo() {
return wsaTo;
}
+ /**
+ * Method setWsaTo
+ *
+ * @param wsaTo
+ */
public void setWsaTo(EndpointReference wsaTo) {
this.wsaTo = wsaTo;
}
+ /**
+ * Method getWsaFrom
+ *
+ * @return
+ */
public EndpointReference getWsaFrom() {
return wsaFrom;
}
+ /**
+ * Method setWsaFrom
+ *
+ * @param wsaFrom
+ */
public void setWsaFrom(EndpointReference wsaFrom) {
this.wsaFrom = wsaFrom;
}
+ /**
+ * Method getWsaReply
+ *
+ * @return
+ */
public EndpointReference getWsaReply() {
return wsaReply;
}
+ /**
+ * Method setWsaReply
+ *
+ * @param wsaReply
+ */
public void setWsaReply(EndpointReference wsaReply) {
this.wsaReply = wsaReply;
}
+ /**
+ * Method getWsaFaultTo
+ *
+ * @return
+ */
public EndpointReference getWsaFaultTo() {
return wsaFaultTo;
}
+ /**
+ * Method setWsaFaultTo
+ *
+ * @param wsaFaultTo
+ */
public void setWsaFaultTo(EndpointReference wsaFaultTo) {
this.wsaFaultTo = wsaFaultTo;
}
+ /**
+ * Method getAction
+ *
+ * @return
+ */
public String getAction() {
return action;
}
+ /**
+ * Method setAction
+ *
+ * @param action
+ */
public void setAction(String action) {
this.action = action;
}
+ /**
+ * Method getMessageId
+ *
+ * @return
+ */
public String getMessageId() {
return messageId;
}
+ /**
+ * Method setMessageId
+ *
+ * @param messageId
+ */
public void setMessageId(String messageId) {
this.messageId = messageId;
}
+ /**
+ * Method getRelatesTo
+ *
+ * @return
+ */
public RelatesTo getRelatesTo() {
return relatesTo;
}
+ /**
+ * Method setRelatesTo
+ *
+ * @param relatesTo
+ */
public void setRelatesTo(RelatesTo relatesTo) {
this.relatesTo = relatesTo;
}
-
// --------------------------------------------------------------------------------------------
-
-
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/AsyncResult.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/AsyncResult.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/AsyncResult.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/AsyncResult.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -17,7 +17,13 @@
import org.apache.axis.om.SOAPEnvelope;
+/**
+ * Class AsyncResult
+ */
public class AsyncResult {
+ /**
+ * Field result
+ */
private SOAPEnvelope result;
/**
@@ -33,5 +39,4 @@
public SOAPEnvelope getResponseEnvelope() {
return result;
}
-
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Call.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Call.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Call.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Call.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -33,35 +33,82 @@
import java.io.IOException;
import java.io.Writer;
+/**
+ * Class Call
+ */
public class Call {
+ /**
+ * Field registry
+ */
private EngineRegistry registry;
+
+ /**
+ * Field log
+ */
protected Log log = LogFactory.getLog(getClass());
+
+ /**
+ * Field targetEPR
+ */
private EndpointReference targetEPR;
+
+ /**
+ * Field useSeparateListener
+ */
private boolean useSeparateListener;
- //only used in SendReciveAync , to get the response
+
+ // only used in SendReciveAync , to get the response
+
+ /**
+ * Field Listenertransport
+ */
private String Listenertransport;
- //the type of transport that the request should be send throgh
+
+ // the type of transport that the request should be send throgh
+
+ /**
+ * Field transport
+ */
private String transport;
+
+ /**
+ * Field action
+ */
private String action;
+ /**
+ * Constructor Call
+ */
public Call() {
- //TODO look for the Client XML and creatre a Engine registy
+ // TODO look for the Client XML and create an Engine registy
this.registry = new EngineRegistryImpl(new AxisGlobal());
Listenertransport = null;
transport = Constants.TRANSPORT_HTTP;
}
+ /**
+ * Method setTo
+ *
+ * @param EPR
+ */
public void setTo(EndpointReference EPR) {
this.targetEPR = EPR;
-
}
+ /**
+ * Method setTransportType
+ *
+ * @param transport
+ * @throws AxisFault
+ */
public void setTransportType(String transport) throws AxisFault {
- if ((Constants.TRANSPORT_HTTP.equals(transport) || Constants.TRANSPORT_SMTP.equals(transport)
+ if ((Constants.TRANSPORT_HTTP.equals(transport)
+ || Constants.TRANSPORT_SMTP.equals(transport)
|| Constants.TRANSPORT_TCP.equals(transport))) {
this.transport = transport;
} else {
- throw new AxisFault("Selected transport dose not suppot ( " + transport + " )");
+ throw new AxisFault("Selected transport dose not suppot ( "
+ + transport + " )");
}
}
@@ -70,17 +117,21 @@
* inoder to have asyn support for tansport , it shoud call this method
*
* @param Listenertransport
+ * @param useSeparateListener
+ * @throws AxisFault
*/
- public void setListenerTransport(String Listenertransport, boolean useSeparateListener) throws AxisFault {
- if ((Constants.TRANSPORT_HTTP.equals(transport) || Constants.TRANSPORT_SMTP.equals(transport)
+ public void setListenerTransport(
+ String Listenertransport, boolean useSeparateListener)
+ throws AxisFault {
+ if ((Constants.TRANSPORT_HTTP.equals(transport)
+ || Constants.TRANSPORT_SMTP.equals(transport)
|| Constants.TRANSPORT_TCP.equals(transport))) {
this.Listenertransport = Listenertransport;
this.useSeparateListener = useSeparateListener;
} else {
- throw new AxisFault("Selected transport dose not suppot ( " + transport + " )");
+ throw new AxisFault("Selected transport dose not suppot ( "
+ + transport + " )");
}
-
-
}
/**
@@ -97,6 +148,7 @@
* todo
*
* @param envelope
+ * @throws AxisFault
*/
public void sendAsync(SOAPEnvelope envelope) throws AxisFault {
Writer out = null;
@@ -105,19 +157,18 @@
MessageContext msgctx = new MessageContext(registry, null, null);
msgctx.setEnvelope(envelope);
msgctx.setTo(targetEPR);
- msgctx.setProperty(
- MessageContext.TRANSPORT_TYPE,
+ msgctx.setProperty(MessageContext.TRANSPORT_TYPE,
Constants.TRANSPORT_HTTP);
msgctx.setTo(targetEPR);
engine.send(msgctx);
-
} catch (IOException e) {
throw AxisFault.makeFault(e);
} finally {
try {
- //TODO This should be the Receiver.close();
- //Receiver is taken using the
- //TransportReceiver reciver = TransportReceiverLocator.locate(requestMessageContext);
+
+ // TODO This should be the Receiver.close();
+ // Receiver is taken using the
+ // TransportReceiver reciver = TransportReceiverLocator.locate(requestMessageContext);
out.close();
} catch (IOException e1) {
throw new AxisFault();
@@ -125,85 +176,95 @@
}
}
+ /**
+ * Method send
+ *
+ * @param envelope
+ * @throws AxisFault
+ */
public void send(SOAPEnvelope envelope) throws AxisFault {
if (Constants.TRANSPORT_SMTP.equals(transport)) {
- throw new AxisFault("This invocation support only for bi-directional transport");
+ throw new AxisFault(
+ "This invocation support only for bi-directional transport");
} else {
MessageContext request = null;
try {
final AxisEngine engine = new AxisEngine(registry);
request = new MessageContext(registry, null, null);
request.setEnvelope(envelope);
- request.setProperty(
- MessageContext.TRANSPORT_TYPE,
- transport);
+ request.setProperty(MessageContext.TRANSPORT_TYPE, transport);
request.setTo(targetEPR);
engine.send(request);
- //todo dose the 202 response come throgh the same connection
- //This is purely HTTP specific.
- //Handle the HTTP 202 respose
- /* MessageContext response =
- new MessageContext(
- registry,
- request.getProperties(),
- request.getSessionContext());*/
-
+ // todo dose the 202 response come throgh the same connection
+ // This is purely HTTP specific.
+ // Handle the HTTP 202 respose
+
+ /*
+ * MessageContext response =
+ * new MessageContext(
+ * registry,
+ * request.getProperties(),
+ * request.getSessionContext());
+ */
request.setServerSide(false);
- request.setProperty(
- MessageContext.TRANSPORT_TYPE,
- transport);
- TransportReceiver receiver = TransportReceiverLocator.locate(request);
+ request.setProperty(MessageContext.TRANSPORT_TYPE, transport);
+ TransportReceiver receiver =
+ TransportReceiverLocator.locate(request);
receiver.invoke(request);
- if (request.getProperty(MessageContext.TRANSPORT_SUCCEED) != null) {
+ if (request.getProperty(MessageContext.TRANSPORT_SUCCEED)
+ != null) {
throw new AxisFault("Sent failed");
} else if (request.getEnvelope().getBody().hasFault()) {
- throw new AxisFault(request.getEnvelope().getBody().getFault().getFaultString());
+ throw new AxisFault(
+ request.getEnvelope().getBody().getFault().getFaultString());
}
} catch (IOException e) {
throw AxisFault.makeFault(e);
} finally {
- Writer writer = (Writer) request.getProperty(MessageContext.TRANSPORT_WRITER);
+ Writer writer = (Writer) request.getProperty(
+ MessageContext.TRANSPORT_WRITER);
if (writer != null) {
try {
writer.close();
} catch (IOException e) {
- throw new AxisFault(e.getMessage());
+ throw new AxisFault(e.getMessage());
}
}
}
}
-
}
+ /**
+ * Method sendReceive
+ *
+ * @param envelope
+ * @return
+ * @throws AxisFault
+ */
public SOAPEnvelope sendReceive(SOAPEnvelope envelope) throws AxisFault {
if (Constants.TRANSPORT_SMTP.equals(transport)) {
- throw new AxisFault("This invocation support only for bi-directional transport");
+ throw new AxisFault(
+ "This invocation support only for bi-directional transport");
}
try {
AxisEngine engine = new AxisEngine(registry);
MessageContext msgctx = new MessageContext(registry, null, null);
msgctx.setEnvelope(envelope);
- msgctx.setProperty(
- MessageContext.TRANSPORT_TYPE,
- transport);
+ msgctx.setProperty(MessageContext.TRANSPORT_TYPE, transport);
msgctx.setTo(targetEPR);
engine.send(msgctx);
- MessageContext response =
- new MessageContext(
- registry,
+ MessageContext response = new MessageContext(registry,
msgctx.getProperties(),
msgctx.getSessionContext());
response.setServerSide(false);
- response.setProperty(
- MessageContext.TRANSPORT_TYPE,
- transport);
- TransportReceiver receiver = TransportReceiverLocator.locate(response);
+ response.setProperty(MessageContext.TRANSPORT_TYPE, transport);
+ TransportReceiver receiver =
+ TransportReceiverLocator.locate(response);
receiver.invoke(response);
SOAPEnvelope resenvelope = response.getEnvelope();
- //TODO if the resenvelope is a SOAPFault then throw an exception
-
+ // TODO if the resenvelope is a SOAPFault then throw an exception
return resenvelope;
} catch (OMException e) {
throw AxisFault.makeFault(e);
@@ -215,30 +276,32 @@
/**
* @param envelope
* @param callback
+ * @throws AxisFault
*/
- public void sendReceiveAsync(
- SOAPEnvelope envelope,
- final Callback callback)
+ public void sendReceiveAsync(SOAPEnvelope envelope, final Callback callback)
throws AxisFault {
try {
AxisEngine engine = new AxisEngine(registry);
- final MessageContext msgctx =
- new MessageContext(registry, null, null);
+ final MessageContext msgctx = new MessageContext(registry, null,
+ null);
msgctx.setEnvelope(envelope);
msgctx.setProperty(MessageContext.TRANSPORT_TYPE, transport);
msgctx.setTo(targetEPR);
if (useSeparateListener) {
if (Constants.TRANSPORT_SMTP.equals(transport)) {
- throw new AxisFault("This invocation support only for bi-directional transport");
+ throw new AxisFault(
+ "This invocation support only for bi-directional transport");
}
- Invoker invoker = new Invoker(msgctx, engine, registry, callback);
+ Invoker invoker = new Invoker(msgctx, engine, registry,
+ callback);
Thread th = new Thread(invoker);
th.start();
} else {
- //TODO
- //start the Listener at the client side
- throw new UnsupportedOperationException("Unblocking transports are not supported yet");
+ // TODO
+ // start the Listener at the client side
+ throw new UnsupportedOperationException(
+ "Unblocking transports are not supported yet");
}
} catch (OMException e) {
throw AxisFault.makeFault(e);
@@ -247,6 +310,11 @@
}
}
+ /**
+ * Method getTO
+ *
+ * @return
+ */
public Object getTO() {
return this.targetEPR;
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Callback.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Callback.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Callback.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Callback.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -15,26 +15,66 @@
*/
package org.apache.axis.clientapi;
+/**
+ * Class Callback
+ */
public abstract class Callback {
+ /**
+ * Field complete
+ */
private boolean complete = false;
+
+ /**
+ * Field result
+ */
private AsyncResult result;
+ /**
+ * Method onComplete
+ *
+ * @param result
+ */
public abstract void onComplete(AsyncResult result);
+ /**
+ * Method reportError
+ *
+ * @param e
+ */
public abstract void reportError(Exception e);
+ /**
+ * Method isComplete
+ *
+ * @return
+ */
public boolean isComplete() {
return complete;
}
+ /**
+ * Method setComplete
+ *
+ * @param complete
+ */
public void setComplete(boolean complete) {
this.complete = complete;
}
+ /**
+ * Method getResult
+ *
+ * @return
+ */
public AsyncResult getResult() {
return result;
}
+ /**
+ * Method setResult
+ *
+ * @param result
+ */
public void setResult(AsyncResult result) {
this.result = result;
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Correlator.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Correlator.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Correlator.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Correlator.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -17,17 +17,33 @@
import java.util.HashMap;
+/**
+ * Class Correlator
+ */
public class Correlator {
+ /**
+ * Field instance
+ */
private static Correlator instance;
+ /**
+ * Field correlationHash
+ */
private static HashMap correlationHash;
+ /**
+ * Constructor Correlator
+ */
private Correlator() {
// Exists only to defeat instantiation.
-
correlationHash = new HashMap(10);
}
+ /**
+ * Method getInstance
+ *
+ * @return
+ */
public static Correlator getInstance() {
if (instance == null) {
instance = new Correlator();
@@ -35,12 +51,23 @@
return instance;
}
+ /**
+ * Method addCorrelationInfo
+ *
+ * @param msgid
+ * @param callbackObj
+ */
public void addCorrelationInfo(String msgid, Callback callbackObj) {
correlationHash.put(msgid, callbackObj);
}
+ /**
+ * Method getCorrelationInfo
+ *
+ * @param MessageID
+ * @return
+ */
public Callback getCorrelationInfo(String MessageID) {
return (Callback) correlationHash.get(MessageID);
}
-
-}
\ No newline at end of file
+}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Invoker.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Invoker.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Invoker.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/clientapi/Invoker.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -21,25 +21,49 @@
import org.apache.axis.transport.TransportReceiver;
import org.apache.axis.transport.TransportReceiverLocator;
+/**
+ * Class Invoker
+ */
public class Invoker implements Runnable {
+ /**
+ * Field engine
+ */
private AxisEngine engine;
+
+ /**
+ * Field registry
+ */
private EngineRegistry registry;
+ /**
+ * Field reqMsgContext
+ */
private MessageContext reqMsgContext;
+ /**
+ * Field callback
+ */
private Callback callback;
- public Invoker(MessageContext msgContext,
- AxisEngine engine,
- EngineRegistry reg,
- Callback callback) {
+ /**
+ * Constructor Invoker
+ *
+ * @param msgContext
+ * @param engine
+ * @param reg
+ * @param callback
+ */
+ public Invoker(MessageContext msgContext, AxisEngine engine,
+ EngineRegistry reg, Callback callback) {
this.engine = engine;
this.reqMsgContext = msgContext;
this.callback = callback;
this.registry = reg;
-
}
+ /**
+ * Method run
+ */
public void run() {
final Correlator correlator = Correlator.getInstance();
final String messageID = Long.toString(System.currentTimeMillis());
@@ -48,10 +72,11 @@
engine.send(reqMsgContext);
correlator.addCorrelationInfo(reqMsgContext.getMessageID(),
callback);
- MessageContext resMsgContext = new MessageContext(registry, reqMsgContext.getProperties(), reqMsgContext.getSessionContext());
+ MessageContext resMsgContext =
+ new MessageContext(registry, reqMsgContext.getProperties(),
+ reqMsgContext.getSessionContext());
resMsgContext.setServerSide(false);
- // resMsgContext.setProperty(MessageContext.TRANSPORT_TYPE,
- // Constants.TRANSPORT_HTTP);
+
TransportReceiver receiver =
TransportReceiverLocator.locate(resMsgContext);
receiver.invoke(resMsgContext);
@@ -63,11 +88,8 @@
callback.setComplete(true);
callback.setResult(result);
callback.onComplete(result);
-
} catch (Exception e) {
callback.reportError(e);
}
-
}
-
-}
\ No newline at end of file
+}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/GlobalContext.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/GlobalContext.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/GlobalContext.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/GlobalContext.java Sun Feb 20 09:56:49 2005
@@ -1,57 +1,79 @@
-/*
- * Copyright 2004,2005 The Apache Software Foundation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.axis.context;
-
-import org.apache.axis.engine.EngineRegistry;
-
-import java.util.HashMap;
-
-/**
- * All the engine componets are stateless accross the executions and all the states should be kept in the
- * Contexts, there are three context Global, Session and Message
- */
-public class GlobalContext {
- private EngineRegistry registry;
- private final HashMap map = new HashMap(10);
-
- public GlobalContext(EngineRegistry er) {
- this.registry = er;
- }
-
- public Object get(Object key) {
- return map.get(key);
- }
-
- public void put(String key, Object obj) {
- map.put(key, obj);
-
- }
-
- /**
- * @return
- */
- public EngineRegistry getRegistry() {
- return registry;
- }
-
- /**
- * @param registry
- */
- public void setRegistry(EngineRegistry registry) {
- this.registry = registry;
- }
-
-}
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.axis.context;
+
+import org.apache.axis.engine.EngineRegistry;
+
+import java.util.HashMap;
+
+/**
+ * All the engine componets are stateless accross the executions and all the states should be kept in the
+ * Contexts, there are three context Global, Session and Message
+ */
+public class GlobalContext {
+ /**
+ * Field registry
+ */
+ private EngineRegistry registry;
+
+ /**
+ * Field map
+ */
+ private final HashMap map = new HashMap(10);
+
+ /**
+ * Constructor GlobalContext
+ *
+ * @param er
+ */
+ public GlobalContext(EngineRegistry er) {
+ this.registry = er;
+ }
+
+ /**
+ * Method get
+ *
+ * @param key
+ * @return
+ */
+ public Object get(Object key) {
+ return map.get(key);
+ }
+
+ /**
+ * Method put
+ *
+ * @param key
+ * @param obj
+ */
+ public void put(String key, Object obj) {
+ map.put(key, obj);
+ }
+
+ /**
+ * @return
+ */
+ public EngineRegistry getRegistry() {
+ return registry;
+ }
+
+ /**
+ * @param registry
+ */
+ public void setRegistry(EngineRegistry registry) {
+ this.registry = registry;
+ }
+}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/MessageContext.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/MessageContext.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/MessageContext.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/MessageContext.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -38,56 +38,170 @@
* artifacts does not keep states foward from the execution.
*/
public class MessageContext {
+ /**
+ * Field messageStyle
+ */
private String messageStyle = WSDLService.STYLE_RPC;
/**
* Follwing are the defined properties that are stored in the message Context
*/
public static final String USER_NAME = "USER";
+
+ /**
+ * Field PASSWORD
+ */
public static final String PASSWORD = "PASSWD";
+
+ /**
+ * Field TRANSPORT_TYPE
+ */
public static final String TRANSPORT_TYPE = "TRANSPORT_TYPE";
+
+ /**
+ * Field SOAP_ACTION
+ */
public static final String SOAP_ACTION = "SOAP_ACTION";
+
+ /**
+ * Field TRANSPORT_WRITER
+ */
public static final String TRANSPORT_WRITER = "TRANSPORT_WRITER";
+
+ /**
+ * Field TRANSPORT_READER
+ */
public static final String TRANSPORT_READER = "TRANSPORT_READER";
+
+ /**
+ * Field TRANSPORT_IN
+ */
public static final String TRANSPORT_IN = "TRANSPORT_IN";
+ /**
+ * Field TRANSPORT_SUCCEED
+ */
public static final String TRANSPORT_SUCCEED = "TRANSPORT_SUCCEED";
- //public static final String REQUEST_URL = "REQUEST_URL";
+ // public static final String REQUEST_URL = "REQUEST_URL";
+
+ /**
+ * Field processingFault
+ */
private boolean processingFault = false;
+
+ /**
+ * Field to
+ */
private EndpointReference to;
+
+ /**
+ * Field from
+ */
private EndpointReference from;
+
+ /**
+ * Field relatesTo
+ */
private RelatesTo relatesTo;
+
+ /**
+ * Field replyTo
+ */
private EndpointReference replyTo;
+
+ /**
+ * Field faultTo
+ */
private EndpointReference faultTo;
+ /**
+ * Field chain
+ */
private ExecutionChain chain;
+
+ /**
+ * Field transport
+ */
private AxisTransport transport;
- //there is a no use cas found to set those proprties
- //so declare them final
+ // there is a no use cas found to set those proprties
+ // so declare them final
+
+ /**
+ * Field properties
+ */
private final Map properties;
+
+ /**
+ * Field globalContext
+ */
private final GlobalContext globalContext;
+ /**
+ * Field sessionContext
+ */
private final SessionContext sessionContext;
+
+ /**
+ * Field service
+ */
private AxisService service;
+
+ /**
+ * Field envelope
+ */
private SOAPEnvelope envelope;
+
+ /**
+ * Field responseWritten
+ */
private boolean responseWritten;
+
+ /**
+ * Field inFaultFlow
+ */
private boolean inFaultFlow;
+
+ /**
+ * Field serverSide
+ */
private boolean serverSide;
+
+ /**
+ * Field messageID
+ */
private String messageID;
+
+ /**
+ * Field operation
+ */
private AxisOperation operation;
+
+ /**
+ * Field newThreadRequired
+ */
private boolean newThreadRequired = false;
+
+ /**
+ * Field xpp
+ */
private XMLStreamReader xpp;
+
+ /**
+ * Field soapOperationElement
+ */
private OMElement soapOperationElement;
/**
- * @param Engine registry
+ * @param er registry
* @param initialProperties of the message context, should be null if no properties
* @param sessionContext of the message context, should be null if no sessionContext
* @throws AxisFault
*/
- public MessageContext(EngineRegistry er, Map initialProperties, SessionContext sessionContext) throws AxisFault {
+ public MessageContext(
+ EngineRegistry er, Map initialProperties, SessionContext sessionContext)
+ throws AxisFault {
this.globalContext = new GlobalContext(er);
if (sessionContext == null) {
this.sessionContext = new SimpleSessionContext();
@@ -151,6 +265,7 @@
}
/**
+ * @param key
* @return
*/
public Object getProperty(Object key) {
@@ -342,6 +457,11 @@
}
}
+ /**
+ * Method getExecutionChain
+ *
+ * @return
+ */
public ExecutionChain getExecutionChain() {
return this.chain;
}
@@ -401,5 +521,4 @@
public Map getProperties() {
return properties;
}
-
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/SessionContext.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/SessionContext.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/SessionContext.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/SessionContext.java Sun Feb 20 09:56:49 2005
@@ -1,26 +1,38 @@
-/*
- * Copyright 2004,2005 The Apache Software Foundation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.axis.context;
-
-/**
- * All the engine componets are stateless accross the executions and all the states should be kept in the
- * Contexts, there are three context Global, Session and Message
- */
-public interface SessionContext {
- public Object get(Object key);
-
- public void put(Object key, Object obj);
-}
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.axis.context;
+
+/**
+ * All the engine componets are stateless accross the executions and all the states should be kept in the
+ * Contexts, there are three context Global, Session and Message
+ */
+public interface SessionContext {
+ /**
+ * Method get
+ *
+ * @param key
+ * @return
+ */
+ public Object get(Object key);
+
+ /**
+ * Method put
+ *
+ * @param key
+ * @param obj
+ */
+ public void put(Object key, Object obj);
+}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/SimpleSessionContext.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/SimpleSessionContext.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/SimpleSessionContext.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/context/SimpleSessionContext.java Sun Feb 20 09:56:49 2005
@@ -1,31 +1,48 @@
-/*
- * Copyright 2004,2005 The Apache Software Foundation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.axis.context;
-
-import java.util.HashMap;
-
-public class SimpleSessionContext implements SessionContext {
- private HashMap map = new HashMap();
-
- public Object get(Object key) {
- return map.get(key);
- }
-
- public void put(Object key, Object obj) {
- map.put(key, obj);
-
- }
-}
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.axis.context;
+
+import java.util.HashMap;
+
+/**
+ * Class SimpleSessionContext
+ */
+public class SimpleSessionContext implements SessionContext {
+ /**
+ * Field map
+ */
+ private HashMap map = new HashMap();
+
+ /**
+ * Method get
+ *
+ * @param key
+ * @return
+ */
+ public Object get(Object key) {
+ return map.get(key);
+ }
+
+ /**
+ * Method put
+ *
+ * @param key
+ * @param obj
+ */
+ public void put(Object key, Object obj) {
+ map.put(key, obj);
+ }
+}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisGlobal.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisGlobal.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisGlobal.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisGlobal.java Sun Feb 20 09:56:49 2005
@@ -1,83 +1,118 @@
-/*
- * Copyright 2004,2005 The Apache Software Foundation.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.axis.description;
-
-import org.apache.axis.engine.AxisFault;
-
-import javax.xml.namespace.QName;
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.List;
-
-/**
- * <p>This holds the information shown in the global scope. The information are all
- * that not goes in to the Transport or a Service. This has two types of Info. </p>
- * <ol>
- * <li>parameters<li>
- * <li>ordered phases<li>
- * <li>names of modules that are ref by the server.xml file, real modues are in the
- * Registry.<li>
- * <ol>
- * <p>Note: handlers in the server.xml file are not suported for M1, only way to put a
- * global handler is via a modules</p>
- */
-public class AxisGlobal implements ParameterInclude, PhasesInclude {
- protected final ParameterInclude paramInclude;
- protected final PhasesInclude phasesInclude;
- protected final List modules;
-
- //TODO provide a way to store name (name attribute value server.xml)
- public AxisGlobal() {
- paramInclude = new ParameterIncludeImpl();
- phasesInclude = new PhasesIncludeImpl();
- modules = new ArrayList();
- }
-
- public void addModule(QName moduleref) {
- modules.add(moduleref);
- }
-
- public Collection getModules() {
- return modules;
- }
-
- public Parameter getParameter(String name) {
- return paramInclude.getParameter(name);
- }
-
- public void addParameter(Parameter param) {
- paramInclude.addParameter(param);
- }
-
- /**
- * @param flow
- * @return
- * @throws AxisFault
- */
- public ArrayList getPhases(int flow) throws AxisFault {
- return phasesInclude.getPhases(flow);
- }
-
- /**
- * @param phases
- * @param flow
- * @throws AxisFault
- */
- public void setPhases(ArrayList phases, int flow) throws AxisFault {
- phasesInclude.setPhases(phases, flow);
- }
-
-}
+/*
+ * Copyright 2004,2005 The Apache Software Foundation.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.axis.description;
+
+import org.apache.axis.engine.AxisFault;
+
+import javax.xml.namespace.QName;
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * <p>This holds the information shown in the global scope. The information are all
+ * that not goes in to the Transport or a Service. This has two types of Info. </p>
+ * <ol>
+ * <li>parameters<li>
+ * <li>ordered phases<li>
+ * <li>names of modules that are ref by the server.xml file, real modues are in the
+ * Registry.<li>
+ * <ol>
+ * <p>Note: handlers in the server.xml file are not suported for M1, only way to put a
+ * global handler is via a modules</p>
+ */
+public class AxisGlobal implements ParameterInclude, PhasesInclude {
+ /**
+ * Field paramInclude
+ */
+ protected final ParameterInclude paramInclude;
+
+ /**
+ * Field phasesInclude
+ */
+ protected final PhasesInclude phasesInclude;
+
+ /**
+ * Field modules
+ */
+ protected final List modules;
+
+ // TODO provide a way to store name (name attribute value server.xml)
+
+ /**
+ * Constructor AxisGlobal
+ */
+ public AxisGlobal() {
+ paramInclude = new ParameterIncludeImpl();
+ phasesInclude = new PhasesIncludeImpl();
+ modules = new ArrayList();
+ }
+
+ /**
+ * Method addModule
+ *
+ * @param moduleref
+ */
+ public void addModule(QName moduleref) {
+ modules.add(moduleref);
+ }
+
+ /**
+ * Method getModules
+ *
+ * @return
+ */
+ public Collection getModules() {
+ return modules;
+ }
+
+ /**
+ * Method getParameter
+ *
+ * @param name
+ * @return
+ */
+ public Parameter getParameter(String name) {
+ return paramInclude.getParameter(name);
+ }
+
+ /**
+ * Method addParameter
+ *
+ * @param param
+ */
+ public void addParameter(Parameter param) {
+ paramInclude.addParameter(param);
+ }
+
+ /**
+ * @param flow
+ * @return
+ * @throws AxisFault
+ */
+ public ArrayList getPhases(int flow) throws AxisFault {
+ return phasesInclude.getPhases(flow);
+ }
+
+ /**
+ * @param phases
+ * @param flow
+ * @throws AxisFault
+ */
+ public void setPhases(ArrayList phases, int flow) throws AxisFault {
+ phasesInclude.setPhases(phases, flow);
+ }
+}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisModule.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisModule.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisModule.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisModule.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -27,14 +27,32 @@
* has a module ref="." or avalible to a single service if service.xml have module ref=".."</p>
*/
public class AxisModule implements FlowInclude, ParameterInclude {
+ /**
+ * Field name
+ */
private QName name;
+ /**
+ * Field flowInclude
+ */
private final FlowInclude flowInclude = new FlowIncludeImpl();
+
+ /**
+ * Field parameters
+ */
private final ParameterInclude parameters = new ParameterIncludeImpl();
+ /**
+ * Constructor AxisModule
+ */
public AxisModule() {
}
+ /**
+ * Constructor AxisModule
+ *
+ * @param name
+ */
public AxisModule(QName name) {
this.name = name;
}
@@ -109,5 +127,4 @@
public void setName(QName name) {
this.name = name;
}
-
}
Modified: webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisOperation.java
URL: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisOperation.java?view=diff&r1=154536&r2=154537
==============================================================================
--- webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisOperation.java (original)
+++ webservices/axis/trunk/java/modules/core/src/java/org/apache/axis/description/AxisOperation.java Sun Feb 20 09:56:49 2005
@@ -1,12 +1,12 @@
/*
* Copyright 2004,2005 The Apache Software Foundation.
- *
+ *
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
- *
+ *
* http://www.apache.org/licenses/LICENSE-2.0
- *
+ *
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.