axis-java-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hemap...@apache.org
Subject svn commit: r109502 - in webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis: context deployment deployment/listener deployment/repositary deployment/repository deployment/repository/utill engine impl/receivers impl/recivers
Date Thu, 02 Dec 2004 13:46:35 GMT
Author: hemapani
Date: Thu Dec  2 05:46:34 2004
New Revision: 109502

URL: http://svn.apache.org/viewcvs?view=rev&rev=109502
Log:
spell checking
Added:
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/HDFileItem.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/UnZipJAR.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/WSInfo.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/WSInfoList.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/EndpointReferance.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/Receiver.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/ReceiverLocator.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/INReciver.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/InOutAsyncReciver.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/InOutSyncReciver.java
Removed:
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repositary/
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/EndPointReferance.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/ReciverLocator.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/recivers/
Modified:
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/context/MessageContext.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/DeploymentEngine.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/listener/RepositaryListenerImpl.java
   webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/AxisEngine.java

Modified: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/context/MessageContext.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/context/MessageContext.java?view=diff&rev=109502&p1=webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/context/MessageContext.java&r1=109501&p2=webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/context/MessageContext.java&r2=109502
==============================================================================
--- webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/context/MessageContext.java
(original)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/context/MessageContext.java
Thu Dec  2 05:46:34 2004
@@ -18,7 +18,7 @@
 
 import org.apache.axis.engine.AxisFault;
 import org.apache.axis.engine.Constants;
-import org.apache.axis.engine.EndPointReferance;
+import org.apache.axis.engine.EndpointReferance;
 import org.apache.axis.engine.Operation;
 import org.apache.axis.engine.Service;
 import org.apache.axis.impl.context.SimpleSessionContext;
@@ -44,11 +44,11 @@
     public static final String TRANSPORT_DATA = "TRANSPORT_DATA";
     
     private boolean processingFault = false;
-    private EndPointReferance to;
-    private EndPointReferance from;
-    private EndPointReferance relatesTo;
-    private EndPointReferance replyTo;
-    private EndPointReferance faultTo;
+    private EndpointReferance to;
+    private EndpointReferance from;
+    private EndpointReferance relatesTo;
+    private EndpointReferance replyTo;
+    private EndpointReferance faultTo;
 
     //there is a no use cas found to set those proprties 
     //so declare them final    
@@ -75,14 +75,14 @@
     /**
      * @return
      */
-    public EndPointReferance getFaultTo() {
+    public EndpointReferance getFaultTo() {
         return faultTo;
     }
 
     /**
      * @return
      */
-    public EndPointReferance getFrom() {
+    public EndpointReferance getFrom() {
         return from;
     }
 
@@ -132,14 +132,14 @@
     /**
      * @return
      */
-    public EndPointReferance getRelatesTo() {
+    public EndpointReferance getRelatesTo() {
         return relatesTo;
     }
 
     /**
      * @return
      */
-    public EndPointReferance getReplyTo() {
+    public EndpointReferance getReplyTo() {
         return replyTo;
     }
 
@@ -167,21 +167,21 @@
     /**
      * @return
      */
-    public EndPointReferance getTo() {
+    public EndpointReferance getTo() {
         return to;
     }
 
     /**
      * @param referance
      */
-    public void setFaultTo(EndPointReferance referance) {
+    public void setFaultTo(EndpointReferance referance) {
         faultTo = referance;
     }
 
     /**
      * @param referance
      */
-    public void setFrom(EndPointReferance referance) {
+    public void setFrom(EndpointReferance referance) {
         from = referance;
     }
 
@@ -224,14 +224,14 @@
     /**
      * @param referance
      */
-    public void setRelatesTo(EndPointReferance referance) {
+    public void setRelatesTo(EndpointReferance referance) {
         relatesTo = referance;
     }
 
     /**
      * @param referance
      */
-    public void setReplyTo(EndPointReferance referance) {
+    public void setReplyTo(EndpointReferance referance) {
         replyTo = referance;
     }
 
@@ -253,7 +253,7 @@
     /**
      * @param referance
      */
-    public void setTo(EndPointReferance referance) {
+    public void setTo(EndpointReferance referance) {
         to = referance;
     }
 

Modified: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/DeploymentEngine.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/DeploymentEngine.java?view=diff&rev=109502&p1=webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/DeploymentEngine.java&r1=109501&p2=webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/DeploymentEngine.java&r2=109502
==============================================================================
--- webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/DeploymentEngine.java
(original)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/DeploymentEngine.java
Thu Dec  2 05:46:34 2004
@@ -16,9 +16,9 @@
 import org.apache.axis.deployment.metadata.ServerMetaData;
 import org.apache.axis.deployment.metadata.ServiceMetaData;
 import org.apache.axis.deployment.metadata.phaserule.PhaseException;
-import org.apache.axis.deployment.repositary.utill.HDFileItem;
-import org.apache.axis.deployment.repositary.utill.UnZipJAR;
-import org.apache.axis.deployment.repositary.utill.WSInfo;
+import org.apache.axis.deployment.repository.utill.HDFileItem;
+import org.apache.axis.deployment.repository.utill.UnZipJAR;
+import org.apache.axis.deployment.repository.utill.WSInfo;
 import org.apache.axis.deployment.scheduler.DeploymentIterator;
 import org.apache.axis.deployment.scheduler.Scheduler;
 import org.apache.axis.deployment.scheduler.SchedulerTask;

Modified: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/listener/RepositaryListenerImpl.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/listener/RepositaryListenerImpl.java?view=diff&rev=109502&p1=webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/listener/RepositaryListenerImpl.java&r1=109501&p2=webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/listener/RepositaryListenerImpl.java&r2=109502
==============================================================================
--- webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/listener/RepositaryListenerImpl.java
(original)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/listener/RepositaryListenerImpl.java
Thu Dec  2 05:46:34 2004
@@ -1,6 +1,6 @@
 package org.apache.axis.deployment.listener;
 
-import org.apache.axis.deployment.repositary.utill.WSInfoList;
+import org.apache.axis.deployment.repository.utill.WSInfoList;
 import org.apache.axis.deployment.DeployCons;
 import org.apache.axis.deployment.DeploymentEngine;
 

Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/HDFileItem.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/HDFileItem.java?view=auto&rev=109502
==============================================================================
--- (empty file)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/HDFileItem.java
Thu Dec  2 05:46:34 2004
@@ -0,0 +1,56 @@
+package org.apache.axis.deployment.repository.utill;
+
+import java.io.File;
+
+/**
+ * Copyright 2001-2004 The Apache Software Foundation.
+ * <p/>
+ * 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
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * 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.
+ *
+ * @author Deepal Jayasinghe
+ *         Oct 18, 2004
+ *         2:54:07 PM
+ *
+ */
+
+/**
+ * HDFileItem = Hot Deployment File Item , to store infromation of the module or servise
+ * item to be deploy
+ */
+public class HDFileItem {
+
+    private File file;
+    private int type;
+
+    public HDFileItem(File file, int type) {
+        this.file = file;
+        this.type = type;
+    }
+
+    public String getName() {
+        return file.getName();
+    }
+
+    public String getAbsolutePath() {
+        return file.getAbsolutePath();
+    }
+
+    public int getType() {
+        return type;
+    }
+
+    public void setType(int type) {
+        this.type = type;
+    }
+
+}

Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/UnZipJAR.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/UnZipJAR.java?view=auto&rev=109502
==============================================================================
--- (empty file)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/UnZipJAR.java
Thu Dec  2 05:46:34 2004
@@ -0,0 +1,97 @@
+package org.apache.axis.deployment.repository.utill;
+
+/**
+ * Copyright 2001-2004 The Apache Software Foundation.
+ * <p/>
+ * 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
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * 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.
+ *
+ * @author Deepal Jayasinghe
+ *         Oct 5, 2004
+ *         2:54:57 PM
+ *
+ */
+
+import java.io.FileInputStream;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipInputStream;
+
+import org.apache.axis.deployment.DeployCons;
+import org.apache.axis.deployment.DeploymentEngine;
+import org.apache.axis.deployment.DeploymentParser;
+import org.apache.axis.deployment.metadata.ModuleMetaData;
+import org.apache.axis.deployment.metadata.ServiceMetaData;
+
+public class UnZipJAR implements DeployCons {
+    final int BUFFER = 2048;
+    /**
+     * This method will unzipService the given jar or aar.
+     * it take two arguments filename and refereance to DeployEngine
+     * @param filename
+     * @param engine
+     */
+    public ServiceMetaData unzipService(String filename, DeploymentEngine engine) {
+        ServiceMetaData service =null;
+        // get attribute values
+        String strArchive = filename;
+        ZipInputStream zin;
+        int entrysize = 0;
+        try {
+            zin = new ZipInputStream(new FileInputStream(strArchive));
+            ZipEntry entry;
+            while ((entry = zin.getNextEntry()) != null) {
+                if (entry.getName().equals(SERVICEXML)) {
+                    DeploymentParser schme = new DeploymentParser(zin, engine, filename);
+                    service = schme.parseServiceXML();
+                    break;
+                }
+            }
+          //  zin.closeEntry();
+            zin.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return service;
+    }
+
+    public ModuleMetaData unzipModule(String filename, DeploymentEngine engine){
+        ModuleMetaData module =null;
+        // get attribute values
+        String strArchive = filename;
+        ZipInputStream zin;
+        int entrysize = 0;
+        try {
+            zin = new ZipInputStream(new FileInputStream(strArchive));
+            ZipEntry entry;
+            while ((entry = zin.getNextEntry()) != null) {
+                if (entry.getName().equals(MODULEXML)) {
+                    DeploymentParser schme = new DeploymentParser(zin, engine, filename);
+                    module = schme.procesModuleXML();
+                    break;
+                }
+            }
+          //  zin.closeEntry();
+            zin.close();
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+        return module;
+    }
+}
+
+
+
+
+
+
+
+

Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/WSInfo.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/WSInfo.java?view=auto&rev=109502
==============================================================================
--- (empty file)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/WSInfo.java
Thu Dec  2 05:46:34 2004
@@ -0,0 +1,59 @@
+package org.apache.axis.deployment.repository.utill;
+
+
+/**
+ * Copyright 2001-2004 The Apache Software Foundation.
+ * <p/>
+ * 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
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * 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.
+ *
+ * @author Deepal Jayasinghe
+ *         Oct 13, 2004
+ *         12:06:31 PM
+ *
+ */
+public class WSInfo {
+
+    private String filename;
+    private long lastmodifieddate;
+    /**
+     * To check whether the file is a module or a servise
+     */
+    private int type;
+
+    public WSInfo(String filename, long lastmodifieddate) {
+        this.filename = filename;
+        this.lastmodifieddate = lastmodifieddate;
+    }
+
+    public WSInfo(String filename, long lastmodifieddate, int type) {
+        this.filename = filename;
+        this.lastmodifieddate = lastmodifieddate;
+        this.type = type;
+    }
+
+    public String getFilename() {
+        return filename;
+    }
+
+    public void setFilename(String filename) {
+        this.filename = filename;
+    }
+
+    public long getLastmodifieddate() {
+        return lastmodifieddate;
+    }
+
+    public void setLastmodifieddate(long lastmodifieddate) {
+        this.lastmodifieddate = lastmodifieddate;
+    }
+}

Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/WSInfoList.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/WSInfoList.java?view=auto&rev=109502
==============================================================================
--- (empty file)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/deployment/repository/utill/WSInfoList.java
Thu Dec  2 05:46:34 2004
@@ -0,0 +1,176 @@
+package org.apache.axis.deployment.repository.utill;
+
+import org.apache.axis.deployment.DeploymentEngine;
+import org.apache.axis.deployment.DeployCons;
+
+import java.util.Iterator;
+import java.util.Vector;
+import java.io.File;
+
+/**
+ * Copyright 2001-2004 The Apache Software Foundation.
+ * <p/>
+ * 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
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * 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.
+ *
+ * @author Deepal Jayasinghe
+ *         Oct 13, 2004
+ *         12:13:11 PM
+ *
+ */
+public class WSInfoList implements DeployCons {
+    /**
+     * This is to store all the jar files in a specified folder (WEB_INF)
+     */
+    private static Vector jarlist = new Vector();
+    public Vector currentjars = new Vector();
+
+    private DeploymentEngine deplorer;
+
+    public WSInfoList(DeploymentEngine deploy_engine) {
+        deplorer = deploy_engine;
+    }
+
+    public static Vector getJarlist() {
+        return jarlist;
+    }
+
+    /**
+     * This method is used to initialize the vector
+     */
+    public void init() {
+        jarlist.removeAllElements();
+    }
+
+    public void addWSInfoItem(File file, int type) {
+        switch (type) {
+            case SERVICE:
+                {
+                    if (!isFileExist(file.getName())) {
+                        WSInfo wsInfo = new WSInfo(file.getName(), file.lastModified(), SERVICE);
+                        jarlist.add(wsInfo);
+                        HDFileItem hdFileItem = new HDFileItem(file, SERVICE);
+                        deplorer.addtowsToDeploy(hdFileItem);//to inform that new web service
is deployed
+                    } else {
+                        WSInfo tempWSInfo = getFileItem(file.getName());
+                        if (isModified(file, tempWSInfo)) {
+                            tempWSInfo.setLastmodifieddate(file.lastModified());
+                            WSInfo wsInfo = new WSInfo(tempWSInfo.getFilename(), tempWSInfo.getLastmodifieddate(),
SERVICE);
+                            deplorer.addtowstoUnDeploy(wsInfo);
+                            HDFileItem hdFileItem = new HDFileItem(file, SERVICE);
+                            deplorer.addtowsToDeploy(hdFileItem);
+
+                        }
+                    }
+                }
+            case MODULE:
+                {
+                    if (!isFileExist(file.getName())) {
+                        WSInfo wsInfo = new WSInfo(file.getName(), file.lastModified(), MODULE);
+                        jarlist.add(wsInfo);
+                        HDFileItem hdFileItem = new HDFileItem(file, MODULE);
+                        deplorer.addtowsToDeploy(hdFileItem);//to inform that new web service
is deployed
+                    } else {
+                        WSInfo tempWSInfo = getFileItem(file.getName());
+                        if (isModified(file, tempWSInfo)) {
+                            tempWSInfo.setLastmodifieddate(file.lastModified());
+                            WSInfo wsInfo = new WSInfo(tempWSInfo.getFilename(), tempWSInfo.getLastmodifieddate(),
MODULE);
+                            deplorer.addtowstoUnDeploy(wsInfo);
+                            HDFileItem hdFileItem = new HDFileItem(file, MODULE);
+                            deplorer.addtowsToDeploy(hdFileItem);
+
+                        }
+                    }
+                }
+        }
+        String jarname = file.getName();
+        currentjars.add(jarname);
+    }
+
+    public WSInfo getFileItem(String filename) {
+        int sise = jarlist.size();
+        for (int i = 0; i < sise; i++) {
+            WSInfo wsInfo = (WSInfo) jarlist.elementAt(i);
+            if (wsInfo.getFilename().equals(filename)) {
+                return wsInfo;
+            }
+        }
+        return null;
+    }
+
+    public boolean isModified(File file, WSInfo wsInfo) {
+        if (wsInfo.getLastmodifieddate() != file.lastModified()) {
+            return true;
+        }
+        return false;
+    }
+
+    public boolean isFileExist(String filename) {
+        if (getFileItem(filename) == null) {
+            return false;
+        } else
+            return true;
+    }
+
+    /**
+     * this is to check , undeploye WS
+     */
+    public void checkForUndeploye() {
+        Iterator iter = jarlist.listIterator();
+        int size = currentjars.size();
+        Vector tempvector = new Vector();
+        tempvector.removeAllElements();
+        String filename = "";
+        boolean exist = false;
+        try {
+            while (iter.hasNext()) {
+                WSInfo fileitem = (WSInfo) iter.next();
+                exist = false;
+                for (int i = 0; i < size; i++) {
+                    filename = (String) currentjars.elementAt(i);
+                    if (filename.equals(fileitem.getFilename())) {
+                        exist = true;
+                        break;
+                    }
+                }
+
+                if (!exist) {
+                    tempvector.add(fileitem);
+                    WSInfo wsInfo = new WSInfo(fileitem.getFilename(), fileitem.getLastmodifieddate());
+                    deplorer.addtowstoUnDeploy(wsInfo);//this is to be undeploye
+                }
+
+            }
+        } catch (Exception e) {
+            //todo handle exc
+        }
+
+        for (int i = 0; i < tempvector.size(); i++) {
+            WSInfo fileItem = (WSInfo) tempvector.elementAt(i);
+            jarlist.removeElement(fileItem);
+        }
+        tempvector.removeAllElements();
+        currentjars.removeAllElements();
+    }
+
+
+    /**
+     *
+     */
+    public void update() {
+        checkForUndeploye();
+        deplorer.doUnDeploye();
+        deplorer.doDeploye();
+
+    }
+
+}

Modified: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/AxisEngine.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/AxisEngine.java?view=diff&rev=109502&p1=webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/AxisEngine.java&r1=109501&p2=webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/AxisEngine.java&r2=109502
==============================================================================
--- webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/AxisEngine.java
(original)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/AxisEngine.java
Thu Dec  2 05:46:34 2004
@@ -72,7 +72,7 @@
             if(mc.isServerSide()){
                 OpNameFinder finder = new OpNameFinder();
                 finder.invoke(mc);
-                Reciver reciver = ReciverLocator.locateReciver(mc);
+                Receiver reciver = ReceiverLocator.locateReciver(mc);
                 reciver.invoke(mc);
             }
         }catch(AxisFault e){

Deleted: /webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/EndPointReferance.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/EndPointReferance.java?view=auto&rev=109501
==============================================================================

Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/EndpointReferance.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/EndpointReferance.java?view=auto&rev=109502
==============================================================================
--- (empty file)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/EndpointReferance.java
Thu Dec  2 05:46:34 2004
@@ -0,0 +1,24 @@
+package org.apache.axis.engine;
+
+/**
+ * Copyright 2001-2004 The Apache Software Foundation.
+ * <p/>
+ * 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
+ * <p/>
+ * http://www.apache.org/licenses/LICENSE-2.0
+ * <p/>
+ * 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.
+ *
+ * @author Axis team
+ * Date: Nov 29, 2004
+ * Time: 10:28:25 AM
+ * 
+ */
+public class EndpointReferance {
+}

Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/Receiver.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/Receiver.java?view=auto&rev=109502
==============================================================================
--- (empty file)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/Receiver.java
Thu Dec  2 05:46:34 2004
@@ -0,0 +1,24 @@
+/*
+ * Copyright 2001-2004 The Apache Software Foundation.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.axis.engine;
+
+
+/**
+ * @author Srinath Perera(hemapani@opensource.lk)
+ */
+public interface Receiver extends Handler{
+}

Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/ReceiverLocator.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/ReceiverLocator.java?view=auto&rev=109502
==============================================================================
--- (empty file)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/ReceiverLocator.java
Thu Dec  2 05:46:34 2004
@@ -0,0 +1,33 @@
+/*
+ * Copyright 2001-2004 The Apache Software Foundation.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.axis.engine;
+
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.impl.receivers.InOutSyncReciver;
+
+/**
+ * @author Srinath Perera(hemapani@opensource.lk)
+ */
+public class ReceiverLocator {
+    public static Receiver locateReciver(MessageContext msgCtx)throws AxisFault{
+        
+        //File wsdlFile = msgCtx.getService().getParameter("wsdlFile");
+        //parse the WSDL find the patterns 
+        //create a reciver
+        return new InOutSyncReciver();
+    }
+}

Deleted: /webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/ReciverLocator.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/engine/ReciverLocator.java?view=auto&rev=109501
==============================================================================

Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/INReciver.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/INReciver.java?view=auto&rev=109502
==============================================================================
--- (empty file)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/INReciver.java
Thu Dec  2 05:46:34 2004
@@ -0,0 +1,24 @@
+/*
+ * Copyright 2001-2004 The Apache Software Foundation.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.axis.impl.receivers;
+
+/**
+ * @author Srinath Perera(hemapani@opensource.lk)
+ */
+public class INReciver {
+
+}

Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/InOutAsyncReciver.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/InOutAsyncReciver.java?view=auto&rev=109502
==============================================================================
--- (empty file)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/InOutAsyncReciver.java
Thu Dec  2 05:46:34 2004
@@ -0,0 +1,24 @@
+/*
+ * Copyright 2001-2004 The Apache Software Foundation.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.axis.impl.receivers;
+
+/**
+ * @author Srinath Perera(hemapani@opensource.lk)
+ */
+public class InOutAsyncReciver {
+
+}

Added: webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/InOutSyncReciver.java
Url: http://svn.apache.org/viewcvs/webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/InOutSyncReciver.java?view=auto&rev=109502
==============================================================================
--- (empty file)
+++ webservices/axis/trunk/java/dev/scratch/prototype2/src/java/org/apache/axis/impl/receivers/InOutSyncReciver.java
Thu Dec  2 05:46:34 2004
@@ -0,0 +1,60 @@
+/*
+ * Copyright 2001-2004 The Apache Software Foundation.
+ * 
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ * 
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ * 
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.axis.impl.receivers;
+
+import org.apache.axis.context.MessageContext;
+import org.apache.axis.engine.AxisFault;
+import org.apache.axis.engine.Provider;
+import org.apache.axis.engine.Receiver;
+import org.apache.axis.engine.Sender;
+import org.apache.axis.impl.handlers.AbstractHandler;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+
+/**
+ * @author Srinath Perera(hemapani@opensource.lk)
+ */
+public class InOutSyncReciver extends AbstractHandler implements Receiver {
+    protected Log log = LogFactory.getLog(getClass()); 
+
+    public void invoke(final MessageContext msgContext) throws AxisFault {
+        if(msgContext.isNewThreadRequired()){
+            Runnable runner = new Runnable() {
+                public void run() {
+                    try{
+                        send(msgContext);
+                    }catch(AxisFault e){
+                        log.error("Exception occured in new thread starting response",e);
+                    }
+                    
+                }
+            }; 
+            Thread thread = new Thread(runner);
+            thread.start();           
+        }else{
+            send(msgContext);
+        }
+    }
+    
+    public void send(MessageContext msgContext)throws AxisFault{
+        Provider provider = msgContext.getService().getProvider();
+        MessageContext outMsgContext = provider.invoke(msgContext);
+        Sender sender = new Sender();
+        sender.send(msgContext);
+    }
+
+}

Mime
View raw message