svn commit: r796851 - in /ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi: OdeConfigProperties.java OdeLifeCycle.java

[mriou]

Author: mriou
Date: Wed Jul 22 19:33:54 2009
New Revision: 796851

URL: http://svn.apache.org/viewvc?rev=796851&view=rev
Log:
ODE-636 Support setting multiple message mappers

Modified:
    
ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi/OdeConfigProperties.java
    
ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java

Modified: 
ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi/OdeConfigProperties.java
URL: 
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi/OdeConfigProperties.java?rev=796851&r1=796850&r2=796851&view=diff
==============================================================================
--- 
ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi/OdeConfigProperties.java
 (original)
+++ 
ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi/OdeConfigProperties.java
 Wed Jul 22 19:33:54 2009
@@ -62,8 +62,8 @@
      * 
      * @return
      */
-    public String getMessageMapper() {
-        return getProperty(PROP_MSGMAPPER, 
JbiWsdl11WrapperMapper.class.getName());
+    public String[] getMessageMappers() {
+        return getProperty(PROP_MSGMAPPER, 
JbiWsdl11WrapperMapper.class.getName()).split("[ ,]");
     }
 
  }

Modified: 
ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java
URL: 
http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java?rev=796851&r1=796850&r2=796851&view=diff
==============================================================================
--- 
ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java
 (original)
+++ 
ode/branches/APACHE_ODE_1.X/jbi/src/main/java/org/apache/ode/jbi/OdeLifeCycle.java
 Wed Jul 22 19:33:54 2009
@@ -143,24 +143,27 @@
 
     @SuppressWarnings("unchecked")
     private void initMappers() throws JBIException {
+        String[] mappers = _ode._config.getMessageMappers();
         Class<Mapper> mapperClass;
-        try {
-            mapperClass = (Class<Mapper>) 
Class.forName(_ode._config.getMessageMapper());
-        } catch (ClassNotFoundException e) {
-            String errmsg = 
__msgs.msgOdeInitMapperClassNotFound(_ode._config.getMessageMapper());
-            __log.error(errmsg);
-            throw new JBIException(errmsg, e);
-        } catch (Throwable t) {
-            String errmsg = 
__msgs.msgOdeInitMapperClassLoadFailed(_ode._config.getMessageMapper());
-            __log.error(errmsg);
-            throw new JBIException(errmsg, t);
-        }
-        try {
-            _ode.registerMapper((Mapper) mapperClass.newInstance());
-        } catch (Throwable t) {
-            String errmsg = 
__msgs.msgOdeInitMapperInstantiationFailed(_ode._config.getMessageMapper());
-            __log.error(errmsg);
-            throw new JBIException(errmsg, t);
+        for (String className : mappers) {
+            try {
+                mapperClass = (Class<Mapper>) Class.forName(className);
+            } catch (ClassNotFoundException e) {
+                String errmsg = 
__msgs.msgOdeInitMapperClassNotFound(className);
+                __log.error(errmsg);
+                throw new JBIException(errmsg, e);
+            } catch (Throwable t) {
+                String errmsg = 
__msgs.msgOdeInitMapperClassLoadFailed(className);
+                __log.error(errmsg);
+                throw new JBIException(errmsg, t);
+            }
+            try {
+                _ode.registerMapper((Mapper) mapperClass.newInstance());
+            } catch (Throwable t) {
+                String errmsg = 
__msgs.msgOdeInitMapperInstantiationFailed(className);
+                __log.error(errmsg);
+                throw new JBIException(errmsg, t);
+            }
         }
     }