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 di...@apache.org on 2007/03/02 00:25:52 UTC
svn commit: r513509 - in
/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment:
POJODeployer.java util/Utils.java
Author: dims
Date: Thu Mar 1 13:29:12 2007
New Revision: 513509
URL: http://svn.apache.org/viewvc?view=rev&rev=513509
Log:
move code that sets the message receivers to the pojodeployer
Modified:
webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment/POJODeployer.java
webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment/util/Utils.java
Modified: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment/POJODeployer.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment/POJODeployer.java?view=diff&rev=513509&r1=513508&r2=513509
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment/POJODeployer.java (original)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment/POJODeployer.java Thu Mar 1 13:29:12 2007
@@ -5,10 +5,13 @@
import org.apache.axis2.deployment.util.Utils;
import org.apache.axis2.description.AxisService;
import org.apache.axis2.description.AxisServiceGroup;
+import org.apache.axis2.description.AxisOperation;
import org.apache.axis2.engine.MessageReceiver;
import org.apache.axis2.util.Loader;
import org.apache.axis2.wsdl.WSDLConstants;
import org.apache.ws.java2wsdl.AnnotationConstants;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
import org.codehaus.jam.JAnnotation;
import org.codehaus.jam.JClass;
import org.codehaus.jam.JamClassIterator;
@@ -16,12 +19,14 @@
import org.codehaus.jam.JamServiceFactory;
import org.codehaus.jam.JamServiceParams;
+import javax.xml.namespace.QName;
import java.io.File;
import java.io.FileInputStream;
import java.lang.reflect.Method;
import java.net.URL;
import java.util.ArrayList;
import java.util.HashMap;
+import java.util.Iterator;
import java.util.zip.ZipEntry;
import java.util.zip.ZipInputStream;
@@ -44,6 +49,8 @@
*/
public class POJODeployer implements Deployer {
+ private static Log log = LogFactory.getLog(POJODeployer.class);
+
private ConfigurationContext configCtx;
//To initialize the deployer
@@ -95,7 +102,7 @@
configCtx.getAxisConfiguration(),
new ArrayList(),
new ArrayList());
-
+ setMessageReceivers(axisService);
configCtx.getAxisConfiguration().addService(axisService);
} else {
HashMap messageReciverMap = new HashMap();
@@ -187,6 +194,7 @@
configCtx.getAxisConfiguration(),
new ArrayList(),
new ArrayList());
+ setMessageReceivers(axisService);
axisServiceList.add(axisService);
}
}
@@ -206,6 +214,38 @@
if (threadClassLoader != null) {
Thread.currentThread().setContextClassLoader(threadClassLoader);
}
+ }
+ }
+
+ public void setMessageReceivers(AxisService service) {
+ Iterator iterator = service.getOperations();
+ while(iterator.hasNext()){
+ AxisOperation operation = (AxisOperation) iterator.next();
+ String MEP = operation.getMessageExchangePattern();
+ if(MEP!=null){
+ try {
+ if(WSDLConstants.WSDL20_2006Constants.MEP_URI_IN_ONLY.equals(MEP)
+ || WSDLConstants.WSDL20_2004_Constants.MEP_URI_IN_ONLY.equals(MEP)){
+ Class inOnlyMessageReceiver = Loader.loadClass(
+ "org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver");
+ MessageReceiver messageReceiver =
+ (MessageReceiver) inOnlyMessageReceiver.newInstance();
+ operation.setMessageReceiver(messageReceiver);
+ } else {
+ Class inoutMessageReceiver = Loader.loadClass(
+ "org.apache.axis2.rpc.receivers.RPCMessageReceiver");
+ MessageReceiver inOutmessageReceiver =
+ (MessageReceiver) inoutMessageReceiver.newInstance();
+ operation.setMessageReceiver(inOutmessageReceiver);
+ }
+ } catch (ClassNotFoundException e) {
+ log.error(e);
+ } catch (InstantiationException e) {
+ log.error(e);
+ } catch (IllegalAccessException e) {
+ log.error(e);
+ }
+ }
}
}
Modified: webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment/util/Utils.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment/util/Utils.java?view=diff&rev=513509&r1=513508&r2=513509
==============================================================================
--- webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment/util/Utils.java (original)
+++ webservices/axis2/trunk/java/modules/kernel/src/org/apache/axis2/deployment/util/Utils.java Thu Mar 1 13:29:12 2007
@@ -374,31 +374,6 @@
if(operation.getInputAction()==null){
operation.setSoapAction("urn:" + opName);
}
- String MEP = operation.getMessageExchangePattern();
- if(MEP!=null){
- try {
- if(WSDLConstants.WSDL20_2006Constants.MEP_URI_IN_ONLY.equals(MEP)
- || WSDLConstants.WSDL20_2004_Constants.MEP_URI_IN_ONLY.equals(MEP)){
- Class inOnlyMessageReceiver = Loader.loadClass(
- "org.apache.axis2.rpc.receivers.RPCInOnlyMessageReceiver");
- MessageReceiver messageReceiver =
- (MessageReceiver) inOnlyMessageReceiver.newInstance();
- operation.setMessageReceiver(messageReceiver);
- } else {
- Class inoutMessageReceiver = Loader.loadClass(
- "org.apache.axis2.rpc.receivers.RPCMessageReceiver");
- MessageReceiver inOutmessageReceiver =
- (MessageReceiver) inoutMessageReceiver.newInstance();
- operation.setMessageReceiver(inOutmessageReceiver);
- }
- } catch (ClassNotFoundException e) {
- log.error(e);
- } catch (InstantiationException e) {
- log.error(e);
- } catch (IllegalAccessException e) {
- log.error(e);
- }
- }
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org