svn commit: r745504 - /camel/trunk/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java

[jstrachan]

Author: jstrachan
Date: Wed Feb 18 12:57:36 2009
New Revision: 745504

URL: http://svn.apache.org/viewvc?rev=745504&view=rev
Log:
added helper method

Modified:
    
camel/trunk/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java

Modified: 
camel/trunk/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java
URL: 
http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java?rev=745504&r1=745503&r2=745504&view=diff
==============================================================================
--- 
camel/trunk/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java 
(original)
+++ 
camel/trunk/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java 
Wed Feb 18 12:57:36 2009
@@ -389,4 +389,18 @@
     public static <T> T lookupBean(Exchange exchange, String name, Class<T> 
type) {
         return exchange.getContext().getRegistry().lookup(name, type);
     }
+
+    /**
+     * Returns the first exchange in the given collection of exchanges which 
has the same exchange ID as the one given
+     * or null if none could be found
+     */
+    public static Exchange getExchangeById(Iterable<Exchange> exchanges, 
String exchangeId) {
+        for (Exchange exchange : exchanges) {
+            String id = exchange.getExchangeId();
+            if (id != null && id.equals(exchangeId)) {
+                return exchange;
+            }
+        }
+        return null;
+    }
 }