cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ff...@apache.org
Subject svn commit: r654064 - in /cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi: JBIDestinationOutputStream.java JBIDispatcherUtil.java
Date Wed, 07 May 2008 10:21:53 GMT
Author: ffang
Date: Wed May  7 03:21:52 2008
New Revision: 654064

URL: http://svn.apache.org/viewvc?rev=654064&view=rev
Log:
[CXF-1574]JBI transport should support copy inbound normalizedmessage property to outbound
normalizedmessage

Modified:
    cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestinationOutputStream.java
    cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java

Modified: cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestinationOutputStream.java
URL: http://svn.apache.org/viewvc/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestinationOutputStream.java?rev=654064&r1=654063&r2=654064&view=diff
==============================================================================
--- cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestinationOutputStream.java
(original)
+++ cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDestinationOutputStream.java
Wed May  7 03:21:52 2008
@@ -21,6 +21,7 @@
 
 import java.io.IOException;
 import java.io.InputStream;
+import java.util.Set;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -106,6 +107,12 @@
                                     .getDataHandler());
                         }
                     }
+                    //copy properties
+                    Set<String> keys = inMessage.keySet();
+                    for (String key : keys) {
+                        msg.setProperty(key, inMessage.get(key));
+                    }
+                    //copy contents
                     msg.setContent(new DOMSource(doc));
                     xchng.setMessage(msg, "out");
                     

Modified: cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java
URL: http://svn.apache.org/viewvc/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java?rev=654064&r1=654063&r2=654064&view=diff
==============================================================================
--- cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java
(original)
+++ cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi/JBIDispatcherUtil.java
Wed May  7 03:21:52 2008
@@ -21,6 +21,7 @@
 
 import java.io.IOException;
 import java.io.InputStream;
+import java.util.Set;
 import java.util.logging.Level;
 import java.util.logging.Logger;
 
@@ -132,9 +133,16 @@
         getLogger().fine("dispatch method: " + opName);
                 
         NormalizedMessage nm = exchange.getMessage("in");
+        
         try {
 
             MessageImpl inMessage = new MessageImpl();
+            Set normalizedMessageProps = nm.getPropertyNames();
+            for (Object name : normalizedMessageProps) {
+                inMessage.put((String)name, nm.getProperty((String)name));
+                
+            }
+                        
             inMessage.put(MessageExchange.class, exchange);
             
             



Mime
View raw message