axis-java-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From d...@apache.org
Subject 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...
Date Thu, 15 Sep 2005 19:07:03 GMT
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



Mime
View raw message