svn commit: r452442 - /incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/SpringTestSupport.java

[js...@apache.org]

Author: jstrachan
Date: Tue Oct  3 05:04:45 2006
New Revision: 452442

URL: http://svn.apache.org/viewvc?view=rev&rev=452442
Log:
added a helper method for testing exchanges

Modified:
    incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/SpringTestSupport.java

Modified: incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/SpringTestSupport.java
URL: http://svn.apache.org/viewvc/incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/SpringTestSupport.java?view=diff&rev=452442&r1=452441&r2=452442
==============================================================================
--- incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/SpringTestSupport.java (original)
+++ incubator/servicemix/trunk/servicemix-core/src/main/java/org/apache/servicemix/tck/SpringTestSupport.java Tue Oct  3 05:04:45 2006
@@ -30,6 +30,8 @@
 
 import javax.jbi.messaging.MessagingException;
 import javax.jbi.messaging.NormalizedMessage;
+import javax.jbi.messaging.MessageExchange;
+import javax.jbi.messaging.ExchangeStatus;
 import javax.xml.parsers.ParserConfigurationException;
 import javax.xml.transform.Source;
 import javax.xml.transform.TransformerException;
@@ -123,6 +125,21 @@
             NormalizedMessage message = (NormalizedMessage) iter.next();
             log.info("Message " + (counter++) + " is: " + message);
             log.info(transformer.contentToString(message));
+        }
+    }
+
+
+    protected void assertExchangeWorked(MessageExchange me) throws Exception {
+        if (me.getStatus() == ExchangeStatus.ERROR) {
+            if (me.getError() != null) {
+                throw me.getError();
+            }
+            else {
+                fail("Received ERROR status");
+            }
+        }
+        else if (me.getFault() != null) {
+            fail("Received fault: " + new SourceTransformer().toString(me.getFault().getContent()));
         }
     }
 }