You are viewing a plain text version of this content. The canonical link for it is here.
Posted to axis-cvs@ws.apache.org by he...@apache.org on 2004/12/02 14:46:35 UTC
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
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);
+ }
+
+}