svn commit: r684500 - in /activemq/camel/trunk/camel-core/src/main/java/org/apache/camel: processor/UnmarshalProcessor.java spi/DataFormat.java

[davsclaus]

Author: davsclaus
Date: Sun Aug 10 06:43:56 2008
New Revision: 684500

URL: http://svn.apache.org/viewvc?rev=684500&view=rev
Log:
Added to DataFormat javadoc that you can mutate the out message to e.g. add 
headers

Modified:
    
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java
    
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/DataFormat.java

Modified: 
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java?rev=684500&r1=684499&r2=684500&view=diff
==============================================================================
--- 
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java
 (original)
+++ 
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/processor/UnmarshalProcessor.java
 Sun Aug 10 06:43:56 2008
@@ -40,7 +40,6 @@
     public void process(Exchange exchange) throws Exception {
         InputStream stream = ExchangeHelper.getMandatoryInBody(exchange, 
InputStream.class);
         try {
-
             // lets setup the out message before we invoke the dataFormat
             // so that it can mutate it if necessary
             Message out = exchange.getOut(true);
@@ -49,7 +48,7 @@
             Object result = dataFormat.unmarshal(exchange, stream);
             out.setBody(result);
         } finally {
-            if (null != stream) {
+            if (stream != null) {
                 stream.close();
             }
         }

Modified: 
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/DataFormat.java
URL: 
http://svn.apache.org/viewvc/activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/DataFormat.java?rev=684500&r1=684499&r2=684500&view=diff
==============================================================================
--- 
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/DataFormat.java
 (original)
+++ 
activemq/camel/trunk/camel-core/src/main/java/org/apache/camel/spi/DataFormat.java
 Sun Aug 10 06:43:56 2008
@@ -39,6 +39,10 @@
 
     /**
      * Unmarshals the given stream into an object.
+     * <p/>
+     * <b>Notice:</b> The result is set as body on the exchange OUT message.
+     * It is possible to mutate the OUT message provided in the given exchange 
parameter.
+     * For instance adding headers to the OUT message will be preserved.
      */
     Object unmarshal(Exchange exchange, InputStream stream) throws Exception;
 }