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/09/15 21:07:03 UTC
svn commit: r289289 [22/134] - in /webservices/axis2/trunk/java: ./ etc/
modules/addressing/ modules/addressing/src/META-INF/
modules/addressing/src/org/apache/axis2/handlers/addressing/
modules/addressing/test-resources/ modules/addressing/test/org/ap...
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractRobustInMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractRobustInMessageReceiver.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractRobustInMessageReceiver.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractRobustInMessageReceiver.java Thu Sep 15 11:52:11 2005
@@ -1,44 +1,44 @@
-/*
- * 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.axis2.receivers;
-
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.context.MessageContext;
-import org.apache.axis2.engine.AxisEngine;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-
-/**
- * This is takes care of the IN-OUT sync MEP in the server side
- */
-public abstract class AbstractRobustInMessageReceiver extends AbstractMessageReceiver {
- protected Log log = LogFactory.getLog(getClass());
-
- public abstract void invokeBusinessLogic(MessageContext inMessage) throws AxisFault;
-
- public final void receive(final MessageContext messgeCtx) throws AxisFault {
- try {
- invokeBusinessLogic(messgeCtx);
- } catch (AxisFault e) {
- AxisEngine engine =
- new AxisEngine(
- messgeCtx.getOperationContext().getServiceContext().getEngineContext());
- MessageContext faultContext = engine.createFaultMessageContext(messgeCtx, e);
- engine.sendFault(faultContext);
- }
- }
-
-}
+/*
+ * 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.axis2.receivers;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.engine.AxisEngine;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+/**
+ * This is takes care of the IN-OUT sync MEP in the server side
+ */
+public abstract class AbstractRobustInMessageReceiver extends AbstractMessageReceiver {
+ protected Log log = LogFactory.getLog(getClass());
+
+ public abstract void invokeBusinessLogic(MessageContext inMessage) throws AxisFault;
+
+ public final void receive(final MessageContext messgeCtx) throws AxisFault {
+ try {
+ invokeBusinessLogic(messgeCtx);
+ } catch (AxisFault e) {
+ AxisEngine engine =
+ new AxisEngine(
+ messgeCtx.getOperationContext().getServiceContext().getEngineContext());
+ MessageContext faultContext = engine.createFaultMessageContext(messgeCtx, e);
+ engine.sendFault(faultContext);
+ }
+ }
+
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/AbstractRobustInMessageReceiver.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOnlyMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOnlyMessageReceiver.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOnlyMessageReceiver.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOnlyMessageReceiver.java Thu Sep 15 11:52:11 2005
@@ -1,150 +1,150 @@
-/*
- * 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.axis2.receivers;
-
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.Constants;
-import org.apache.axis2.context.MessageContext;
-import org.apache.axis2.description.OperationDescription;
-import org.apache.axis2.engine.DependencyManager;
-import org.apache.axis2.engine.MessageReceiver;
-import org.apache.axis2.i18n.Messages;
-import org.apache.axis2.om.OMAbstractFactory;
-import org.apache.axis2.om.OMElement;
-import org.apache.axis2.om.OMNamespace;
-import org.apache.axis2.soap.SOAPEnvelope;
-import org.apache.axis2.soap.SOAPFactory;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.wsdl.WSDLService;
-
-import java.lang.reflect.Method;
-
-/**
- * This is a Simple java Provider.
- */
-public class RawXMLINOnlyMessageReceiver
- extends AbstractInMessageReceiver
- implements MessageReceiver {
- /**
- * Field log
- */
- protected Log log = LogFactory.getLog(getClass());
-
- /**
- * Field scope
- */
- private String scope;
-
- /**
- * Field method
- */
- private Method method;
-
- /**
- * Field classLoader
- */
- private ClassLoader classLoader;
-
- /**
- * Constructor RawXMLProvider
- */
- public RawXMLINOnlyMessageReceiver() {
- scope = Constants.APPLICATION_SCOPE;
- }
-
- public void invokeBusinessLogic(MessageContext msgContext)
- throws AxisFault {
- try {
-
- // get the implementation class for the Web Service
- Object obj = getTheImplementationObject(msgContext);
-
- // find the WebService method
- Class ImplClass = obj.getClass();
- DependencyManager.configureBusinessLogicProvider(obj, msgContext, null);
-
- OperationDescription op = msgContext.getOperationContext()
- .getAxisOperation();
- if (op == null) {
- throw new AxisFault(
- "Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider");
- }
- String methodName = op.getName().getLocalPart();
- Method[] methods = ImplClass.getMethods();
- for (int i = 0; i < methods.length; i++) {
- if (methods[i].getName().equals(methodName)) {
- this.method = methods[i];
- break;
- }
- }
- Class[] parameters = method.getParameterTypes();
- if ((parameters != null)
- && (parameters.length == 1)
- &&
- OMElement.class.getName().equals(parameters[0].getName())) {
- OMElement methodElement = msgContext.getEnvelope().getBody()
- .getFirstElement();
-
- OMElement parmeter = null;
- SOAPEnvelope envelope = null;
-
- String style = msgContext.getOperationContext()
- .getAxisOperation()
- .getStyle();
-
- if (WSDLService.STYLE_DOC.equals(style)) {
- parmeter = methodElement;
- Object[] parms = new Object[]{parmeter};
-
- // invoke the WebService
- OMElement result = (OMElement) method.invoke(obj, parms);
- envelope =
- OMAbstractFactory.getSOAP11Factory()
- .getDefaultEnvelope();
- envelope.getBody().setFirstChild(result);
-
- } else if (WSDLService.STYLE_RPC.equals(style)) {
- parmeter = methodElement.getFirstElement();
- Object[] parms = new Object[]{parmeter};
-
- // invoke the WebService
- OMElement result = (OMElement) method.invoke(obj, parms);
- SOAPFactory fac = OMAbstractFactory.getSOAP11Factory();
- envelope = fac.getDefaultEnvelope();
-
- OMNamespace ns = fac.createOMNamespace("http://soapenc/",
- "res");
- OMElement responseMethodName = fac.createOMElement(
- methodName + "Response", ns);
- if (result != null) {
- responseMethodName.addChild(result);
- }
- if (responseMethodName != null) {
- envelope.getBody().addChild(responseMethodName);
- }
- } else {
- throw new AxisFault(Messages.getMessage("unknownStyle",style));
- }
- } else {
- throw new AxisFault(Messages.getMessage("rawXmlProivdeIsLimited"));
- }
- } catch (Exception e) {
- throw AxisFault.makeFault(e);
- }
-
- }
-}
+/*
+ * 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.axis2.receivers;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.description.OperationDescription;
+import org.apache.axis2.engine.DependencyManager;
+import org.apache.axis2.engine.MessageReceiver;
+import org.apache.axis2.i18n.Messages;
+import org.apache.axis2.om.OMAbstractFactory;
+import org.apache.axis2.om.OMElement;
+import org.apache.axis2.om.OMNamespace;
+import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.axis2.soap.SOAPFactory;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.wsdl.WSDLService;
+
+import java.lang.reflect.Method;
+
+/**
+ * This is a Simple java Provider.
+ */
+public class RawXMLINOnlyMessageReceiver
+ extends AbstractInMessageReceiver
+ implements MessageReceiver {
+ /**
+ * Field log
+ */
+ protected Log log = LogFactory.getLog(getClass());
+
+ /**
+ * Field scope
+ */
+ private String scope;
+
+ /**
+ * Field method
+ */
+ private Method method;
+
+ /**
+ * Field classLoader
+ */
+ private ClassLoader classLoader;
+
+ /**
+ * Constructor RawXMLProvider
+ */
+ public RawXMLINOnlyMessageReceiver() {
+ scope = Constants.APPLICATION_SCOPE;
+ }
+
+ public void invokeBusinessLogic(MessageContext msgContext)
+ throws AxisFault {
+ try {
+
+ // get the implementation class for the Web Service
+ Object obj = getTheImplementationObject(msgContext);
+
+ // find the WebService method
+ Class ImplClass = obj.getClass();
+ DependencyManager.configureBusinessLogicProvider(obj, msgContext, null);
+
+ OperationDescription op = msgContext.getOperationContext()
+ .getAxisOperation();
+ if (op == null) {
+ throw new AxisFault(
+ "Operation is not located, if this is doclit style the SOAP-ACTION should specified via the SOAP Action to use the RawXMLProvider");
+ }
+ String methodName = op.getName().getLocalPart();
+ Method[] methods = ImplClass.getMethods();
+ for (int i = 0; i < methods.length; i++) {
+ if (methods[i].getName().equals(methodName)) {
+ this.method = methods[i];
+ break;
+ }
+ }
+ Class[] parameters = method.getParameterTypes();
+ if ((parameters != null)
+ && (parameters.length == 1)
+ &&
+ OMElement.class.getName().equals(parameters[0].getName())) {
+ OMElement methodElement = msgContext.getEnvelope().getBody()
+ .getFirstElement();
+
+ OMElement parmeter = null;
+ SOAPEnvelope envelope = null;
+
+ String style = msgContext.getOperationContext()
+ .getAxisOperation()
+ .getStyle();
+
+ if (WSDLService.STYLE_DOC.equals(style)) {
+ parmeter = methodElement;
+ Object[] parms = new Object[]{parmeter};
+
+ // invoke the WebService
+ OMElement result = (OMElement) method.invoke(obj, parms);
+ envelope =
+ OMAbstractFactory.getSOAP11Factory()
+ .getDefaultEnvelope();
+ envelope.getBody().setFirstChild(result);
+
+ } else if (WSDLService.STYLE_RPC.equals(style)) {
+ parmeter = methodElement.getFirstElement();
+ Object[] parms = new Object[]{parmeter};
+
+ // invoke the WebService
+ OMElement result = (OMElement) method.invoke(obj, parms);
+ SOAPFactory fac = OMAbstractFactory.getSOAP11Factory();
+ envelope = fac.getDefaultEnvelope();
+
+ OMNamespace ns = fac.createOMNamespace("http://soapenc/",
+ "res");
+ OMElement responseMethodName = fac.createOMElement(
+ methodName + "Response", ns);
+ if (result != null) {
+ responseMethodName.addChild(result);
+ }
+ if (responseMethodName != null) {
+ envelope.getBody().addChild(responseMethodName);
+ }
+ } else {
+ throw new AxisFault(Messages.getMessage("unknownStyle",style));
+ }
+ } else {
+ throw new AxisFault(Messages.getMessage("rawXmlProivdeIsLimited"));
+ }
+ } catch (Exception e) {
+ throw AxisFault.makeFault(e);
+ }
+
+ }
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOnlyMessageReceiver.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOutMessageReceiver.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOutMessageReceiver.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOutMessageReceiver.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOutMessageReceiver.java Thu Sep 15 11:52:11 2005
@@ -1,158 +1,158 @@
-/*
- * 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.axis2.receivers;
-
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.Constants;
-import org.apache.axis2.context.MessageContext;
-import org.apache.axis2.description.OperationDescription;
-import org.apache.axis2.engine.DependencyManager;
-import org.apache.axis2.engine.MessageReceiver;
-import org.apache.axis2.i18n.Messages;
-import org.apache.axis2.om.OMElement;
-import org.apache.axis2.om.OMNamespace;
-import org.apache.axis2.soap.SOAPEnvelope;
-import org.apache.commons.logging.Log;
-import org.apache.commons.logging.LogFactory;
-import org.apache.wsdl.WSDLService;
-
-import java.lang.reflect.Method;
-
-/**
- * This is a Simple java Provider.
- */
-public class RawXMLINOutMessageReceiver
- extends AbstractInOutSyncMessageReceiver
- implements MessageReceiver {
- /**
- * Field log
- */
- protected Log log = LogFactory.getLog(getClass());
-
- /**
- * Field scope
- */
- private String scope;
-
- /**
- * Field classLoader
- */
- private ClassLoader classLoader;
-
- /**
- * Constructor RawXMLProvider
- */
- public RawXMLINOutMessageReceiver() {
- scope = Constants.APPLICATION_SCOPE;
- }
-
- public void invokeBusinessLogic(MessageContext msgContext,
- MessageContext newmsgContext)
- throws AxisFault {
- try {
-
- // get the implementation class for the Web Service
- Object obj = getTheImplementationObject(msgContext);
-
- // find the WebService method
- Class ImplClass = obj.getClass();
-
- //Inject the Message Context if it is asked for
- DependencyManager.configureBusinessLogicProvider(obj, msgContext, newmsgContext);
-
- OperationDescription opDesc = msgContext.getOperationContext()
- .getAxisOperation();
- Method method = findOperation(opDesc, ImplClass);
- if (method != null) {
- String style = msgContext.getOperationContext()
- .getAxisOperation()
- .getStyle();
-
- Class[] parameters = method.getParameterTypes();
- Object[] args = null;
-
- if (parameters == null || parameters.length == 0) {
- args = new Object[0];
- } else if (parameters.length == 1) {
- OMElement omElement = null;
- if (WSDLService.STYLE_DOC.equals(style)) {
- omElement =
- msgContext.getEnvelope().getBody()
- .getFirstElement();
- } else if (WSDLService.STYLE_RPC.equals(style)) {
- OMElement operationElement = msgContext.getEnvelope()
- .getBody()
- .getFirstElement();
- if (operationElement != null) {
- if (operationElement.getLocalName() != null &&
- operationElement.getLocalName().startsWith(
- method.getName())) {
- omElement = operationElement.getFirstElement();
- } else {
- throw new AxisFault(Messages.getMessage("AandBdonotmatch","Operation Name","immediate child name",operationElement.getLocalName(),method.getName()));
- }
- } else {
- throw new AxisFault(Messages.getMessage("rpcNeedmatchingChild"));
- }
- } else {
- throw new AxisFault(Messages.getMessage("unknownStyle",style));
- }
- args = new Object[]{omElement};
- } else {
- throw new AxisFault(Messages.getMessage("rawXmlProivdeIsLimited"));
- }
-
- OMElement result = (OMElement) method.invoke(obj, args);
-
- OMElement bodyContent = null;
- if (WSDLService.STYLE_RPC.equals(style)) {
- OMNamespace ns = getSOAPFactory().createOMNamespace(
- "http://soapenc/", "res");
- bodyContent =
- getSOAPFactory().createOMElement(
- method.getName() + "Response", ns);
- bodyContent.addChild(result);
- } else {
- bodyContent = result;
- }
-
- SOAPEnvelope envelope = getSOAPFactory().getDefaultEnvelope();
- if (bodyContent != null) {
- envelope.getBody().addChild(bodyContent);
- }
- newmsgContext.setEnvelope(envelope);
- } else {
- throw new AxisFault(Messages.getMessage("methodNotImplemented",opDesc.getName().toString()));
- }
- } catch (Exception e) {
- throw AxisFault.makeFault(e);
- }
-
- }
-
- public Method findOperation(OperationDescription op, Class ImplClass) {
- Method method = null;
- String methodName = op.getName().getLocalPart();
- Method[] methods = ImplClass.getMethods();
- for (int i = 0; i < methods.length; i++) {
- if (methods[i].getName().equals(methodName)) {
- method = methods[i];
- break;
- }
- }
- return method;
- }
-}
+/*
+ * 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.axis2.receivers;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.description.OperationDescription;
+import org.apache.axis2.engine.DependencyManager;
+import org.apache.axis2.engine.MessageReceiver;
+import org.apache.axis2.i18n.Messages;
+import org.apache.axis2.om.OMElement;
+import org.apache.axis2.om.OMNamespace;
+import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.apache.wsdl.WSDLService;
+
+import java.lang.reflect.Method;
+
+/**
+ * This is a Simple java Provider.
+ */
+public class RawXMLINOutMessageReceiver
+ extends AbstractInOutSyncMessageReceiver
+ implements MessageReceiver {
+ /**
+ * Field log
+ */
+ protected Log log = LogFactory.getLog(getClass());
+
+ /**
+ * Field scope
+ */
+ private String scope;
+
+ /**
+ * Field classLoader
+ */
+ private ClassLoader classLoader;
+
+ /**
+ * Constructor RawXMLProvider
+ */
+ public RawXMLINOutMessageReceiver() {
+ scope = Constants.APPLICATION_SCOPE;
+ }
+
+ public void invokeBusinessLogic(MessageContext msgContext,
+ MessageContext newmsgContext)
+ throws AxisFault {
+ try {
+
+ // get the implementation class for the Web Service
+ Object obj = getTheImplementationObject(msgContext);
+
+ // find the WebService method
+ Class ImplClass = obj.getClass();
+
+ //Inject the Message Context if it is asked for
+ DependencyManager.configureBusinessLogicProvider(obj, msgContext, newmsgContext);
+
+ OperationDescription opDesc = msgContext.getOperationContext()
+ .getAxisOperation();
+ Method method = findOperation(opDesc, ImplClass);
+ if (method != null) {
+ String style = msgContext.getOperationContext()
+ .getAxisOperation()
+ .getStyle();
+
+ Class[] parameters = method.getParameterTypes();
+ Object[] args = null;
+
+ if (parameters == null || parameters.length == 0) {
+ args = new Object[0];
+ } else if (parameters.length == 1) {
+ OMElement omElement = null;
+ if (WSDLService.STYLE_DOC.equals(style)) {
+ omElement =
+ msgContext.getEnvelope().getBody()
+ .getFirstElement();
+ } else if (WSDLService.STYLE_RPC.equals(style)) {
+ OMElement operationElement = msgContext.getEnvelope()
+ .getBody()
+ .getFirstElement();
+ if (operationElement != null) {
+ if (operationElement.getLocalName() != null &&
+ operationElement.getLocalName().startsWith(
+ method.getName())) {
+ omElement = operationElement.getFirstElement();
+ } else {
+ throw new AxisFault(Messages.getMessage("AandBdonotmatch","Operation Name","immediate child name",operationElement.getLocalName(),method.getName()));
+ }
+ } else {
+ throw new AxisFault(Messages.getMessage("rpcNeedmatchingChild"));
+ }
+ } else {
+ throw new AxisFault(Messages.getMessage("unknownStyle",style));
+ }
+ args = new Object[]{omElement};
+ } else {
+ throw new AxisFault(Messages.getMessage("rawXmlProivdeIsLimited"));
+ }
+
+ OMElement result = (OMElement) method.invoke(obj, args);
+
+ OMElement bodyContent = null;
+ if (WSDLService.STYLE_RPC.equals(style)) {
+ OMNamespace ns = getSOAPFactory().createOMNamespace(
+ "http://soapenc/", "res");
+ bodyContent =
+ getSOAPFactory().createOMElement(
+ method.getName() + "Response", ns);
+ bodyContent.addChild(result);
+ } else {
+ bodyContent = result;
+ }
+
+ SOAPEnvelope envelope = getSOAPFactory().getDefaultEnvelope();
+ if (bodyContent != null) {
+ envelope.getBody().addChild(bodyContent);
+ }
+ newmsgContext.setEnvelope(envelope);
+ } else {
+ throw new AxisFault(Messages.getMessage("methodNotImplemented",opDesc.getName().toString()));
+ }
+ } catch (Exception e) {
+ throw AxisFault.makeFault(e);
+ }
+
+ }
+
+ public Method findOperation(OperationDescription op, Class ImplClass) {
+ Method method = null;
+ String methodName = op.getName().getLocalPart();
+ Method[] methods = ImplClass.getMethods();
+ for (int i = 0; i < methods.length; i++) {
+ if (methods[i].getName().equals(methodName)) {
+ method = methods[i];
+ break;
+ }
+ }
+ return method;
+ }
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/RawXMLINOutMessageReceiver.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/ServerCallback.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/ServerCallback.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/ServerCallback.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/ServerCallback.java Thu Sep 15 11:52:11 2005
@@ -1,26 +1,26 @@
-/*
- * 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.axis2.receivers;
-
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.context.MessageContext;
-
-
-public interface ServerCallback {
- public void handleResult(MessageContext result) throws AxisFault;
-
- public void handleFault(AxisFault fault) throws AxisFault;
-}
+/*
+ * 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.axis2.receivers;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.MessageContext;
+
+
+public interface ServerCallback {
+ public void handleResult(MessageContext result) throws AxisFault;
+
+ public void handleFault(AxisFault fault) throws AxisFault;
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/receivers/ServerCallback.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/AxisStorage.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/AxisStorage.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/AxisStorage.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/AxisStorage.java Thu Sep 15 11:52:11 2005
@@ -1,55 +1,55 @@
-package org.apache.axis2.storage;
-
-import org.apache.axis2.description.ParameterInclude;
-
-/*
- * 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.
- *
- *
- */
-
-public interface AxisStorage extends ParameterInclude {
-
- /**
- * puts a value to the storage
- *
- * @param value
- * @return the key as an Object
- */
- Object put(Object value);
-
- /**
- * get a value from the storage. The value is not removed
- *
- * @param key
- * @return the value as an Object
- */
- Object get(Object key);
-
- /**
- * Removes an object from the storage given the key.
- *
- * @param key
- * @return the value being removed as an object
- */
- Object remove(Object key);
-
- /**
- * Cleans the whole storage.
- *
- * @return a boolean saying whether the clean was successful or not
- */
- boolean clean();
-}
+package org.apache.axis2.storage;
+
+import org.apache.axis2.description.ParameterInclude;
+
+/*
+ * 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.
+ *
+ *
+ */
+
+public interface AxisStorage extends ParameterInclude {
+
+ /**
+ * puts a value to the storage
+ *
+ * @param value
+ * @return the key as an Object
+ */
+ Object put(Object value);
+
+ /**
+ * get a value from the storage. The value is not removed
+ *
+ * @param key
+ * @return the value as an Object
+ */
+ Object get(Object key);
+
+ /**
+ * Removes an object from the storage given the key.
+ *
+ * @param key
+ * @return the value being removed as an object
+ */
+ Object remove(Object key);
+
+ /**
+ * Cleans the whole storage.
+ *
+ * @return a boolean saying whether the clean was successful or not
+ */
+ boolean clean();
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/AxisStorage.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AbstractStorage.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AbstractStorage.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AbstractStorage.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AbstractStorage.java Thu Sep 15 11:52:11 2005
@@ -1,33 +1,33 @@
-package org.apache.axis2.storage.impl;
-
-import org.apache.axis2.storage.AxisStorage;
-
-/*
- * 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.
- *
- *
- */
-
-public abstract class AbstractStorage implements AxisStorage {
-
- private static int key = 0;
-
- protected String getUniqueKey() {
- if (key == Integer.MAX_VALUE) {
- key = 0;
- }
- return Integer.toString(key++);
- }
-}
+package org.apache.axis2.storage.impl;
+
+import org.apache.axis2.storage.AxisStorage;
+
+/*
+ * 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.
+ *
+ *
+ */
+
+public abstract class AbstractStorage implements AxisStorage {
+
+ private static int key = 0;
+
+ protected String getUniqueKey() {
+ if (key == Integer.MAX_VALUE) {
+ key = 0;
+ }
+ return Integer.toString(key++);
+ }
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AbstractStorage.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisFileStorage.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisFileStorage.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisFileStorage.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisFileStorage.java Thu Sep 15 11:52:11 2005
@@ -1,129 +1,129 @@
-package org.apache.axis2.storage.impl;
-
-import org.apache.axis2.description.Parameter;
-import org.apache.axis2.description.ParameterIncludeImpl;
-import org.apache.axis2.description.ParameterInclude;
-import org.apache.axis2.AxisFault;
-
-import java.io.File;
-import java.io.FileNotFoundException;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.util.HashMap;
-import java.util.ArrayList;
-
-/*
- * 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.
- *
- *
- */
-
-public class AxisFileStorage extends AbstractStorage {
-
- private File file;
- private FileOutputStream fos;
- private HashMap map;
- private ParameterInclude paramter;
-
- public AxisFileStorage() {
- map = new HashMap();
- paramter = new ParameterIncludeImpl();
- }
-
- public AxisFileStorage(File file) {
- this();
- this.setFile(file);
- }
-
- public File getFile() {
- return file;
- }
-
- public void setFile(File file) {
- try {
- this.file = file;
- this.fos = new FileOutputStream(file);
- } catch (FileNotFoundException e) {
- throw new UnsupportedOperationException("No such file!");
- }
- }
-
- public Object put(Object value) {
-
- try {
- String key = getUniqueKey();
- map.put(key, value);
-
- updateFileState();
-
- return key;
- } catch (IOException e) {
- throw new UnsupportedOperationException(e.getMessage());
- } catch (Exception e) {
- throw new UnsupportedOperationException(e.getMessage());
- }
-
- }
-
- public Object get(Object key) {
- return map.get(key);
- }
-
- public Object remove(Object key) {
- try {
- Object objToRemove = map.remove(key);
-
- updateFileState();
-
- return objToRemove;
- } catch (IOException e) {
- throw new UnsupportedOperationException(" file writing failed!");
- }
- }
-
- private void updateFileState() throws IOException {
-// ObjectOutput out = new ObjectOutputStream(fos);
-// out.writeObject(map);
-// out.close();
- }
-
- public boolean clean() {
- try {
- map.clear();
- updateFileState();
- return true;
- } catch (Exception e) {
- return false;
- }
- }
-
-
- public void addParameter(Parameter param) throws AxisFault{
- paramter.addParameter(param);
- }
-
- public Parameter getParameter(String name) {
- return paramter.getParameter(name);
- }
-
- public ArrayList getParameters() {
- return paramter.getParameters();
- }
-
- //to check whether the paramter is locked at any levle
- public boolean isParamterLocked(String paramterName) {
- return paramter.isParamterLocked(paramterName);
- }
-}
+package org.apache.axis2.storage.impl;
+
+import org.apache.axis2.description.Parameter;
+import org.apache.axis2.description.ParameterIncludeImpl;
+import org.apache.axis2.description.ParameterInclude;
+import org.apache.axis2.AxisFault;
+
+import java.io.File;
+import java.io.FileNotFoundException;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.util.HashMap;
+import java.util.ArrayList;
+
+/*
+ * 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.
+ *
+ *
+ */
+
+public class AxisFileStorage extends AbstractStorage {
+
+ private File file;
+ private FileOutputStream fos;
+ private HashMap map;
+ private ParameterInclude paramter;
+
+ public AxisFileStorage() {
+ map = new HashMap();
+ paramter = new ParameterIncludeImpl();
+ }
+
+ public AxisFileStorage(File file) {
+ this();
+ this.setFile(file);
+ }
+
+ public File getFile() {
+ return file;
+ }
+
+ public void setFile(File file) {
+ try {
+ this.file = file;
+ this.fos = new FileOutputStream(file);
+ } catch (FileNotFoundException e) {
+ throw new UnsupportedOperationException("No such file!");
+ }
+ }
+
+ public Object put(Object value) {
+
+ try {
+ String key = getUniqueKey();
+ map.put(key, value);
+
+ updateFileState();
+
+ return key;
+ } catch (IOException e) {
+ throw new UnsupportedOperationException(e.getMessage());
+ } catch (Exception e) {
+ throw new UnsupportedOperationException(e.getMessage());
+ }
+
+ }
+
+ public Object get(Object key) {
+ return map.get(key);
+ }
+
+ public Object remove(Object key) {
+ try {
+ Object objToRemove = map.remove(key);
+
+ updateFileState();
+
+ return objToRemove;
+ } catch (IOException e) {
+ throw new UnsupportedOperationException(" file writing failed!");
+ }
+ }
+
+ private void updateFileState() throws IOException {
+// ObjectOutput out = new ObjectOutputStream(fos);
+// out.writeObject(map);
+// out.close();
+ }
+
+ public boolean clean() {
+ try {
+ map.clear();
+ updateFileState();
+ return true;
+ } catch (Exception e) {
+ return false;
+ }
+ }
+
+
+ public void addParameter(Parameter param) throws AxisFault{
+ paramter.addParameter(param);
+ }
+
+ public Parameter getParameter(String name) {
+ return paramter.getParameter(name);
+ }
+
+ public ArrayList getParameters() {
+ return paramter.getParameters();
+ }
+
+ //to check whether the paramter is locked at any levle
+ public boolean isParamterLocked(String paramterName) {
+ return paramter.isParamterLocked(paramterName);
+ }
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisFileStorage.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisMemoryStorage.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisMemoryStorage.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisMemoryStorage.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisMemoryStorage.java Thu Sep 15 11:52:11 2005
@@ -1,84 +1,84 @@
-package org.apache.axis2.storage.impl;
-
-import org.apache.axis2.description.Parameter;
-import org.apache.axis2.description.ParameterInclude;
-import org.apache.axis2.description.ParameterIncludeImpl;
-import org.apache.axis2.AxisFault;
-
-import java.util.HashMap;
-import java.util.ArrayList;
-
-/*
-* 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.
-*
-*
-*/
-
-public class AxisMemoryStorage extends AbstractStorage {
-
- private HashMap objectMap;
- private ParameterInclude paramter;
-
-
- public AxisMemoryStorage() {
- objectMap = new HashMap();
- paramter = new ParameterIncludeImpl();
- }
-
- public Object put(Object value) {
- String key = getUniqueKey();
- objectMap.put(key, value);
- return key;
-
- }
-
- public Object get(Object key) {
- return objectMap.get(key);
- }
-
- public Object remove(Object key) {
- return objectMap.remove(key);
- }
-
- public boolean clean() {
- boolean returnValue = false;
- try {
- objectMap.clear();
- returnValue = true;
- } catch (Exception e) {
- returnValue = false;
- }
- return returnValue;
- }
-
-
- public void addParameter(Parameter param) throws AxisFault {
- paramter.addParameter(param);
- }
-
- public Parameter getParameter(String name) {
- return paramter.getParameter(name);
- }
-
- public ArrayList getParameters() {
- return paramter.getParameters();
- }
-
- //to check whether the paramter is locked at any levle
- public boolean isParamterLocked(String paramterName) {
- return paramter.isParamterLocked(paramterName);
- }
-
-}
+package org.apache.axis2.storage.impl;
+
+import org.apache.axis2.description.Parameter;
+import org.apache.axis2.description.ParameterInclude;
+import org.apache.axis2.description.ParameterIncludeImpl;
+import org.apache.axis2.AxisFault;
+
+import java.util.HashMap;
+import java.util.ArrayList;
+
+/*
+* 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.
+*
+*
+*/
+
+public class AxisMemoryStorage extends AbstractStorage {
+
+ private HashMap objectMap;
+ private ParameterInclude paramter;
+
+
+ public AxisMemoryStorage() {
+ objectMap = new HashMap();
+ paramter = new ParameterIncludeImpl();
+ }
+
+ public Object put(Object value) {
+ String key = getUniqueKey();
+ objectMap.put(key, value);
+ return key;
+
+ }
+
+ public Object get(Object key) {
+ return objectMap.get(key);
+ }
+
+ public Object remove(Object key) {
+ return objectMap.remove(key);
+ }
+
+ public boolean clean() {
+ boolean returnValue = false;
+ try {
+ objectMap.clear();
+ returnValue = true;
+ } catch (Exception e) {
+ returnValue = false;
+ }
+ return returnValue;
+ }
+
+
+ public void addParameter(Parameter param) throws AxisFault {
+ paramter.addParameter(param);
+ }
+
+ public Parameter getParameter(String name) {
+ return paramter.getParameter(name);
+ }
+
+ public ArrayList getParameters() {
+ return paramter.getParameters();
+ }
+
+ //to check whether the paramter is locked at any levle
+ public boolean isParamterLocked(String paramterName) {
+ return paramter.isParamterLocked(paramterName);
+ }
+
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/storage/impl/AxisMemoryStorage.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/AbstractTransportSender.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/EmailReceiver.java
------------------------------------------------------------------------------
svn:eol-style = native
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportListener.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportSender.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportSender.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportSender.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportSender.java Thu Sep 15 11:52:11 2005
@@ -1,44 +1,44 @@
-/*
- * 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.axis2.transport;
-
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.context.ConfigurationContext;
-import org.apache.axis2.context.MessageContext;
-import org.apache.axis2.description.TransportOutDescription;
-import org.apache.axis2.engine.Handler;
-
-/**
- * This send the SOAP Message to other SOAP nodes and this alone write the SOAP Message to the
- * wire. Out flow must be end with one of this kind.
- */
-public interface TransportSender extends Handler {
- /**
- * Initialize
- * @param confContext
- * @param transportOut
- * @throws org.apache.axis2.AxisFault
- */
- public void init(ConfigurationContext confContext,
- TransportOutDescription transportOut) throws AxisFault;
- /**
- * Clean up
- * @param msgContext
- * @throws org.apache.axis2.AxisFault
- */
- public void cleanUp(MessageContext msgContext) throws AxisFault;
-
-}
+/*
+ * 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.axis2.transport;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.description.TransportOutDescription;
+import org.apache.axis2.engine.Handler;
+
+/**
+ * This send the SOAP Message to other SOAP nodes and this alone write the SOAP Message to the
+ * wire. Out flow must be end with one of this kind.
+ */
+public interface TransportSender extends Handler {
+ /**
+ * Initialize
+ * @param confContext
+ * @param transportOut
+ * @throws org.apache.axis2.AxisFault
+ */
+ public void init(ConfigurationContext confContext,
+ TransportOutDescription transportOut) throws AxisFault;
+ /**
+ * Clean up
+ * @param msgContext
+ * @throws org.apache.axis2.AxisFault
+ */
+ public void cleanUp(MessageContext msgContext) throws AxisFault;
+
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportSender.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportUtils.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportUtils.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportUtils.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportUtils.java Thu Sep 15 11:52:11 2005
@@ -1,100 +1,100 @@
-/*
- * 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.axis2.transport;
-
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.context.MessageContext;
-import org.apache.axis2.context.OperationContext;
-import org.apache.axis2.i18n.Messages;
-import org.apache.axis2.om.impl.llom.builder.StAXBuilder;
-import org.apache.axis2.om.impl.llom.builder.StAXOMBuilder;
-import org.apache.axis2.soap.SOAPEnvelope;
-import org.apache.axis2.soap.SOAPFactory;
-import org.apache.axis2.soap.impl.llom.builder.StAXSOAPModelBuilder;
-import org.apache.axis2.soap.impl.llom.soap11.SOAP11Factory;
-import org.apache.axis2.transport.http.HTTPConstants;
-import org.apache.axis2.transport.http.HTTPTransportUtils;
-
-import javax.xml.stream.XMLInputFactory;
-import javax.xml.stream.XMLStreamReader;
-import java.io.InputStream;
-
-public class TransportUtils {
- public static SOAPEnvelope createSOAPMessage(MessageContext msgContext, String soapNamespaceURI) throws AxisFault {
-
- InputStream inStream = (InputStream) msgContext.getProperty(
- MessageContext.TRANSPORT_IN);
- msgContext.setProperty(MessageContext.TRANSPORT_IN, null);
- //this inputstram is set by the TransportSender represents a two way transport or
- //by a Transport Recevier
- if (inStream == null) {
- throw new AxisFault(Messages.getMessage("inputstreamNull"));
- }
- return createSOAPMessage(msgContext, inStream, soapNamespaceURI);
- }
-
- private static SOAPEnvelope createSOAPMessage(MessageContext msgContext,
- InputStream inStream, String soapNamespaceURI)
- throws AxisFault {
- try {
- Object contentType = null;
- OperationContext opContext = msgContext.getOperationContext();
- if (opContext != null) {
- contentType =
- opContext.getProperty(
- HTTPConstants.MTOM_RECIVED_CONTENT_TYPE);
- } else {
- throw new AxisFault(Messages.getMessage("cannotBeNullOperationContext"));
- }
-
- StAXBuilder builder = null;
- SOAPEnvelope envelope = null;
-
- String charSetEnc = (String)msgContext.getProperty(MessageContext.CHARACTER_SET_ENCODING);
- if(charSetEnc == null) {
- charSetEnc = MessageContext.DEFAULT_CHAR_SET_ENCODING;
- }
-
- if (contentType != null) {
- msgContext.setDoingMTOM(true);
- builder =
- HTTPTransportUtils.selectBuilderForMIME(msgContext,
- inStream,
- (String) contentType);
- envelope = (SOAPEnvelope) builder.getDocumentElement();
- } else if (msgContext.isDoingREST()) {
- XMLStreamReader xmlreader =
- XMLInputFactory.newInstance().createXMLStreamReader(
- inStream,charSetEnc);
- SOAPFactory soapFactory = new SOAP11Factory();
- builder = new StAXOMBuilder(xmlreader);
- builder.setOmbuilderFactory(soapFactory);
- envelope = soapFactory.getDefaultEnvelope();
- envelope.getBody().addChild(builder.getDocumentElement());
- } else {
- XMLStreamReader xmlreader =
- XMLInputFactory.newInstance().createXMLStreamReader(
- inStream,charSetEnc);
- builder = new StAXSOAPModelBuilder(xmlreader, soapNamespaceURI);
- envelope = (SOAPEnvelope) builder.getDocumentElement();
- }
- return envelope;
- } catch (Exception e) {
- throw new AxisFault(e);
- }
- }
-
-}
+/*
+ * 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.axis2.transport;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.context.OperationContext;
+import org.apache.axis2.i18n.Messages;
+import org.apache.axis2.om.impl.llom.builder.StAXBuilder;
+import org.apache.axis2.om.impl.llom.builder.StAXOMBuilder;
+import org.apache.axis2.soap.SOAPEnvelope;
+import org.apache.axis2.soap.SOAPFactory;
+import org.apache.axis2.soap.impl.llom.builder.StAXSOAPModelBuilder;
+import org.apache.axis2.soap.impl.llom.soap11.SOAP11Factory;
+import org.apache.axis2.transport.http.HTTPConstants;
+import org.apache.axis2.transport.http.HTTPTransportUtils;
+
+import javax.xml.stream.XMLInputFactory;
+import javax.xml.stream.XMLStreamReader;
+import java.io.InputStream;
+
+public class TransportUtils {
+ public static SOAPEnvelope createSOAPMessage(MessageContext msgContext, String soapNamespaceURI) throws AxisFault {
+
+ InputStream inStream = (InputStream) msgContext.getProperty(
+ MessageContext.TRANSPORT_IN);
+ msgContext.setProperty(MessageContext.TRANSPORT_IN, null);
+ //this inputstram is set by the TransportSender represents a two way transport or
+ //by a Transport Recevier
+ if (inStream == null) {
+ throw new AxisFault(Messages.getMessage("inputstreamNull"));
+ }
+ return createSOAPMessage(msgContext, inStream, soapNamespaceURI);
+ }
+
+ private static SOAPEnvelope createSOAPMessage(MessageContext msgContext,
+ InputStream inStream, String soapNamespaceURI)
+ throws AxisFault {
+ try {
+ Object contentType = null;
+ OperationContext opContext = msgContext.getOperationContext();
+ if (opContext != null) {
+ contentType =
+ opContext.getProperty(
+ HTTPConstants.MTOM_RECIVED_CONTENT_TYPE);
+ } else {
+ throw new AxisFault(Messages.getMessage("cannotBeNullOperationContext"));
+ }
+
+ StAXBuilder builder = null;
+ SOAPEnvelope envelope = null;
+
+ String charSetEnc = (String)msgContext.getProperty(MessageContext.CHARACTER_SET_ENCODING);
+ if(charSetEnc == null) {
+ charSetEnc = MessageContext.DEFAULT_CHAR_SET_ENCODING;
+ }
+
+ if (contentType != null) {
+ msgContext.setDoingMTOM(true);
+ builder =
+ HTTPTransportUtils.selectBuilderForMIME(msgContext,
+ inStream,
+ (String) contentType);
+ envelope = (SOAPEnvelope) builder.getDocumentElement();
+ } else if (msgContext.isDoingREST()) {
+ XMLStreamReader xmlreader =
+ XMLInputFactory.newInstance().createXMLStreamReader(
+ inStream,charSetEnc);
+ SOAPFactory soapFactory = new SOAP11Factory();
+ builder = new StAXOMBuilder(xmlreader);
+ builder.setOmbuilderFactory(soapFactory);
+ envelope = soapFactory.getDefaultEnvelope();
+ envelope.getBody().addChild(builder.getDocumentElement());
+ } else {
+ XMLStreamReader xmlreader =
+ XMLInputFactory.newInstance().createXMLStreamReader(
+ inStream,charSetEnc);
+ builder = new StAXSOAPModelBuilder(xmlreader, soapNamespaceURI);
+ envelope = (SOAPEnvelope) builder.getDocumentElement();
+ }
+ return envelope;
+ } catch (Exception e) {
+ throw new AxisFault(e);
+ }
+ }
+
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/TransportUtils.java
------------------------------------------------------------------------------
svn:eol-style = native
Modified: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/http/AxisServlet.java
URL: http://svn.apache.org/viewcvs/webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/http/AxisServlet.java?rev=289289&r1=289288&r2=289289&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/http/AxisServlet.java (original)
+++ webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/http/AxisServlet.java Thu Sep 15 11:52:11 2005
@@ -1,225 +1,225 @@
-/*
-* 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.axis2.transport.http;
-
-import org.apache.axis2.AxisFault;
-import org.apache.axis2.Constants;
-import org.apache.axis2.context.ConfigurationContext;
-import org.apache.axis2.context.ConfigurationContextFactory;
-import org.apache.axis2.context.MessageContext;
-import org.apache.axis2.context.SessionContext;
-import org.apache.axis2.engine.AxisEngine;
-
-import javax.servlet.ServletConfig;
-import javax.servlet.ServletContext;
-import javax.servlet.ServletException;
-import javax.servlet.http.HttpServlet;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import javax.xml.namespace.QName;
-import java.io.File;
-import java.io.IOException;
-import java.io.OutputStream;
-import java.util.Enumeration;
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * Class AxisServlet
- */
-public class AxisServlet extends HttpServlet {
- private ListingAgent lister;
- private static final String CONFIGURATION_CONTEXT = "CONFIGURATION_CONTEXT";
- private ConfigurationContext configContext;
-
- /**
- * Method init
- *
- * @param config
- * @throws ServletException
- */
- public void init(ServletConfig config) throws ServletException {
- try {
- ServletContext context = config.getServletContext();
- String repoDir = context.getRealPath("/WEB-INF");
- ConfigurationContextFactory erfac =
- new ConfigurationContextFactory();
- configContext =
- erfac.buildConfigurationContext(repoDir);
- configContext.setProperty(Constants.CONTAINER_MANAGED,
- Constants.VALUE_TRUE);
- configContext.setRootDir(new File(context.getRealPath("/WEB-INF")));
- lister = new ListingAgent(configContext);
- context.setAttribute(CONFIGURATION_CONTEXT, configContext);
- } catch (Exception e) {
- throw new ServletException(e);
- }
- }
-
- /**
- * Method doGet
- *
- * @param httpServletRequest
- * @param httpServletResponse
- * @throws ServletException
- * @throws IOException
- */
- protected void doGet(HttpServletRequest httpServletRequest,
- HttpServletResponse httpServletResponse)
- throws ServletException, IOException {
-
- MessageContext msgContext = null;
- OutputStream out = null;
- try {
- Object sessionContext =
- httpServletRequest.getSession().getAttribute(Constants.SESSION_CONTEXT_PROPERTY);
- if (sessionContext == null) {
- sessionContext = new SessionContext(null);
- httpServletRequest.getSession().setAttribute(Constants.SESSION_CONTEXT_PROPERTY,
- sessionContext);
- }
-
- Enumeration enu = httpServletRequest.getParameterNames();
- HashMap map = new HashMap();
- while (enu.hasMoreElements()) {
- String name = (String) enu.nextElement();
- String value = httpServletRequest.getParameter(name);
- map.put(name, value);
- }
-
- msgContext =
- new MessageContext(configContext,
- (SessionContext) sessionContext,
- configContext.getAxisConfiguration().getTransportIn(new QName(Constants.TRANSPORT_HTTP)),
- configContext.getAxisConfiguration().getTransportOut(new QName(Constants.TRANSPORT_HTTP)));
- msgContext.setDoingREST(true);
- msgContext.setServerSide(true);
- msgContext.setProperty(HTTPConstants.HTTPOutTransportInfo,
- new ServletBasedOutTransportInfo(httpServletResponse));
- msgContext.setProperty(MessageContext.TRANSPORT_HEADERS, getTransportHeaders(httpServletRequest));
-
- out = httpServletResponse.getOutputStream();
- msgContext.setServiceGroupContextId(httpServletRequest.getSession().getId());
- boolean processed =
- HTTPTransportUtils.processHTTPGetRequest(msgContext,
- httpServletRequest.getInputStream(),
- out,
- httpServletRequest.getContentType(),
- httpServletRequest.getHeader(HTTPConstants.HEADER_SOAP_ACTION),
- httpServletRequest.getRequestURL().toString(),
- configContext,
- map);
- if (!processed) {
- lister.handle(httpServletRequest, httpServletResponse, out);
- }
- } catch (AxisFault e) {
- if (msgContext != null) {
- msgContext.setProperty(MessageContext.TRANSPORT_OUT, out);
- AxisEngine engine = new AxisEngine(configContext);
- MessageContext faultContext =
- engine.createFaultMessageContext(msgContext, e);
- engine.sendFault(faultContext);
- } else {
- throw new ServletException(e);
- }
- } catch (Exception e) {
- throw new ServletException(e);
- }
-
- }
-
- /*
- * (non-Javadoc)
- * @see javax.servlet.http.HttpServlet#doPost(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse)
- */
-
- /**
- * Method doPost
- *
- * @param req
- * @param res
- * @throws ServletException
- * @throws IOException
- */
- protected void doPost(HttpServletRequest req, HttpServletResponse res)
- throws ServletException, IOException {
- MessageContext msgContext = null;
- OutputStream out = null;
- try {
- Object sessionContext =
- req.getSession().getAttribute(Constants.SESSION_CONTEXT_PROPERTY);
- if (sessionContext == null) {
- sessionContext = new SessionContext(null);
- req.getSession().setAttribute(Constants.SESSION_CONTEXT_PROPERTY,
- sessionContext);
- }
- msgContext =
- new MessageContext(configContext,
- (SessionContext) sessionContext,
- configContext.getAxisConfiguration().getTransportIn(new QName(Constants.TRANSPORT_HTTP)),
- configContext.getAxisConfiguration().getTransportOut(new QName(Constants.TRANSPORT_HTTP)));
- msgContext.setProperty(HTTPConstants.HTTPOutTransportInfo,
- new ServletBasedOutTransportInfo(res));
- msgContext.setProperty(MessageContext.TRANSPORT_HEADERS, getTransportHeaders(req));
-
- out = res.getOutputStream();
- HTTPTransportUtils.processHTTPPostRequest(msgContext,
- req.getInputStream(),
- out,
- req.getContentType(),
- req.getHeader(HTTPConstants.HEADER_SOAP_ACTION),
- req.getRequestURL().toString(),
- configContext);
-
- Object contextWritten =
- msgContext.getOperationContext().getProperty(Constants.RESPONSE_WRITTEN);
-
- //Getting the
- res.setContentType("text/xml; charset="+
- msgContext
- .getProperty(MessageContext.CHARACTER_SET_ENCODING));
-
- if (contextWritten == null
- || !Constants.VALUE_TRUE.equals(contextWritten)) {
- res.setStatus(HttpServletResponse.SC_ACCEPTED);
- }
- } catch (AxisFault e) {
- if (msgContext != null) {
- res.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
- msgContext.setProperty(MessageContext.TRANSPORT_OUT,
- out);
- AxisEngine engine = new AxisEngine(configContext);
- MessageContext faultContext =
- engine.createFaultMessageContext(msgContext, e);
- engine.sendFault(faultContext);
- } else {
- throw new ServletException(e);
- }
- }
- }
-
- private Map getTransportHeaders(HttpServletRequest req) {
- HashMap headerMap = new HashMap();
- Enumeration headerNames = req.getHeaderNames();
- while (headerNames.hasMoreElements()) {
- String key = (String) headerNames.nextElement();
- String value = req.getHeader(key);
- headerMap.put(key, value);
- }
- return headerMap;
- }
-
-}
+/*
+* 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.axis2.transport.http;
+
+import org.apache.axis2.AxisFault;
+import org.apache.axis2.Constants;
+import org.apache.axis2.context.ConfigurationContext;
+import org.apache.axis2.context.ConfigurationContextFactory;
+import org.apache.axis2.context.MessageContext;
+import org.apache.axis2.context.SessionContext;
+import org.apache.axis2.engine.AxisEngine;
+
+import javax.servlet.ServletConfig;
+import javax.servlet.ServletContext;
+import javax.servlet.ServletException;
+import javax.servlet.http.HttpServlet;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.xml.namespace.QName;
+import java.io.File;
+import java.io.IOException;
+import java.io.OutputStream;
+import java.util.Enumeration;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * Class AxisServlet
+ */
+public class AxisServlet extends HttpServlet {
+ private ListingAgent lister;
+ private static final String CONFIGURATION_CONTEXT = "CONFIGURATION_CONTEXT";
+ private ConfigurationContext configContext;
+
+ /**
+ * Method init
+ *
+ * @param config
+ * @throws ServletException
+ */
+ public void init(ServletConfig config) throws ServletException {
+ try {
+ ServletContext context = config.getServletContext();
+ String repoDir = context.getRealPath("/WEB-INF");
+ ConfigurationContextFactory erfac =
+ new ConfigurationContextFactory();
+ configContext =
+ erfac.buildConfigurationContext(repoDir);
+ configContext.setProperty(Constants.CONTAINER_MANAGED,
+ Constants.VALUE_TRUE);
+ configContext.setRootDir(new File(context.getRealPath("/WEB-INF")));
+ lister = new ListingAgent(configContext);
+ context.setAttribute(CONFIGURATION_CONTEXT, configContext);
+ } catch (Exception e) {
+ throw new ServletException(e);
+ }
+ }
+
+ /**
+ * Method doGet
+ *
+ * @param httpServletRequest
+ * @param httpServletResponse
+ * @throws ServletException
+ * @throws IOException
+ */
+ protected void doGet(HttpServletRequest httpServletRequest,
+ HttpServletResponse httpServletResponse)
+ throws ServletException, IOException {
+
+ MessageContext msgContext = null;
+ OutputStream out = null;
+ try {
+ Object sessionContext =
+ httpServletRequest.getSession().getAttribute(Constants.SESSION_CONTEXT_PROPERTY);
+ if (sessionContext == null) {
+ sessionContext = new SessionContext(null);
+ httpServletRequest.getSession().setAttribute(Constants.SESSION_CONTEXT_PROPERTY,
+ sessionContext);
+ }
+
+ Enumeration enu = httpServletRequest.getParameterNames();
+ HashMap map = new HashMap();
+ while (enu.hasMoreElements()) {
+ String name = (String) enu.nextElement();
+ String value = httpServletRequest.getParameter(name);
+ map.put(name, value);
+ }
+
+ msgContext =
+ new MessageContext(configContext,
+ (SessionContext) sessionContext,
+ configContext.getAxisConfiguration().getTransportIn(new QName(Constants.TRANSPORT_HTTP)),
+ configContext.getAxisConfiguration().getTransportOut(new QName(Constants.TRANSPORT_HTTP)));
+ msgContext.setDoingREST(true);
+ msgContext.setServerSide(true);
+ msgContext.setProperty(HTTPConstants.HTTPOutTransportInfo,
+ new ServletBasedOutTransportInfo(httpServletResponse));
+ msgContext.setProperty(MessageContext.TRANSPORT_HEADERS, getTransportHeaders(httpServletRequest));
+
+ out = httpServletResponse.getOutputStream();
+ msgContext.setServiceGroupContextId(httpServletRequest.getSession().getId());
+ boolean processed =
+ HTTPTransportUtils.processHTTPGetRequest(msgContext,
+ httpServletRequest.getInputStream(),
+ out,
+ httpServletRequest.getContentType(),
+ httpServletRequest.getHeader(HTTPConstants.HEADER_SOAP_ACTION),
+ httpServletRequest.getRequestURL().toString(),
+ configContext,
+ map);
+ if (!processed) {
+ lister.handle(httpServletRequest, httpServletResponse, out);
+ }
+ } catch (AxisFault e) {
+ if (msgContext != null) {
+ msgContext.setProperty(MessageContext.TRANSPORT_OUT, out);
+ AxisEngine engine = new AxisEngine(configContext);
+ MessageContext faultContext =
+ engine.createFaultMessageContext(msgContext, e);
+ engine.sendFault(faultContext);
+ } else {
+ throw new ServletException(e);
+ }
+ } catch (Exception e) {
+ throw new ServletException(e);
+ }
+
+ }
+
+ /*
+ * (non-Javadoc)
+ * @see javax.servlet.http.HttpServlet#doPost(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse)
+ */
+
+ /**
+ * Method doPost
+ *
+ * @param req
+ * @param res
+ * @throws ServletException
+ * @throws IOException
+ */
+ protected void doPost(HttpServletRequest req, HttpServletResponse res)
+ throws ServletException, IOException {
+ MessageContext msgContext = null;
+ OutputStream out = null;
+ try {
+ Object sessionContext =
+ req.getSession().getAttribute(Constants.SESSION_CONTEXT_PROPERTY);
+ if (sessionContext == null) {
+ sessionContext = new SessionContext(null);
+ req.getSession().setAttribute(Constants.SESSION_CONTEXT_PROPERTY,
+ sessionContext);
+ }
+ msgContext =
+ new MessageContext(configContext,
+ (SessionContext) sessionContext,
+ configContext.getAxisConfiguration().getTransportIn(new QName(Constants.TRANSPORT_HTTP)),
+ configContext.getAxisConfiguration().getTransportOut(new QName(Constants.TRANSPORT_HTTP)));
+ msgContext.setProperty(HTTPConstants.HTTPOutTransportInfo,
+ new ServletBasedOutTransportInfo(res));
+ msgContext.setProperty(MessageContext.TRANSPORT_HEADERS, getTransportHeaders(req));
+
+ out = res.getOutputStream();
+ HTTPTransportUtils.processHTTPPostRequest(msgContext,
+ req.getInputStream(),
+ out,
+ req.getContentType(),
+ req.getHeader(HTTPConstants.HEADER_SOAP_ACTION),
+ req.getRequestURL().toString(),
+ configContext);
+
+ Object contextWritten =
+ msgContext.getOperationContext().getProperty(Constants.RESPONSE_WRITTEN);
+
+ //Getting the
+ res.setContentType("text/xml; charset="+
+ msgContext
+ .getProperty(MessageContext.CHARACTER_SET_ENCODING));
+
+ if (contextWritten == null
+ || !Constants.VALUE_TRUE.equals(contextWritten)) {
+ res.setStatus(HttpServletResponse.SC_ACCEPTED);
+ }
+ } catch (AxisFault e) {
+ if (msgContext != null) {
+ res.setStatus(HttpServletResponse.SC_INTERNAL_SERVER_ERROR);
+ msgContext.setProperty(MessageContext.TRANSPORT_OUT,
+ out);
+ AxisEngine engine = new AxisEngine(configContext);
+ MessageContext faultContext =
+ engine.createFaultMessageContext(msgContext, e);
+ engine.sendFault(faultContext);
+ } else {
+ throw new ServletException(e);
+ }
+ }
+ }
+
+ private Map getTransportHeaders(HttpServletRequest req) {
+ HashMap headerMap = new HashMap();
+ Enumeration headerNames = req.getHeaderNames();
+ while (headerNames.hasMoreElements()) {
+ String key = (String) headerNames.nextElement();
+ String value = req.getHeader(key);
+ headerMap.put(key, value);
+ }
+ return headerMap;
+ }
+
+}
Propchange: webservices/axis2/trunk/java/modules/core/src/org/apache/axis2/transport/http/AxisServlet.java
------------------------------------------------------------------------------
svn:eol-style = native