[jboss-svn-commits] JBL Code SVN: r6599 - labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners

[jboss-svn-commits at lists.jboss.org]

Author: estebanschifman
Date: 2006-10-04 14:07:56 -0400 (Wed, 04 Oct 2006)
New Revision: 6599

Modified:
   labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/MessageBox.java
Log:
Change signature of process(Object) to process(Message)

Modified: labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/MessageBox.java
===================================================================
--- labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/MessageBox.java	2006-10-04 17:59:09 UTC (rev 6598)
+++ labs/jbossesb/trunk/qa/junit/src/org/jboss/soa/esb/listeners/MessageBox.java	2006-10-04 18:07:56 UTC (rev 6599)
@@ -31,6 +31,7 @@
 import org.apache.log4j.Logger;
 import org.jboss.soa.esb.actions.ActionProcessingException;
 import org.jboss.soa.esb.actions.ActionProcessor;
+import org.jboss.soa.esb.message.Message;
 
 /**
  * 
@@ -45,11 +46,13 @@
     /* (non-Javadoc)
      * @see org.jboss.soa.esb.actions.ActionProcessor#process(java.lang.Object)
      */
-    public Object process(Object message) throws ActionProcessingException {
+    public void process(Message message) throws ActionProcessingException {
+    	Object oCurr = message.getBody().get(ActionProcessor.CURRENT_OBJECT);
+    	if (null==oCurr)
+    		oCurr="<null>";
         logger.info("MessageBox received message: " + message);
-        messages.add(message);
+        messages.add(oCurr);
         
-        return message;
     }
 
     public static void assertMessageCount(int count, long maxWait) {