You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by ff...@apache.org on 2008/05/07 12:21:53 UTC
svn commit: r654064 - in
/cxf/trunk/rt/transports/jbi/src/main/java/org/apache/cxf/transport/jbi:
JBIDestinationOutputStream.java JBIDispatcherUtil.java
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);