[jboss-svn-commits] JBL Code SVN: r14721 - labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/soa/esb/schedule.

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

Author: kevin.conner at jboss.com
Date: 2007-08-29 05:41:13 -0400 (Wed, 29 Aug 2007)
New Revision: 14721

Modified:
   labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/soa/esb/schedule/MockScheduledEventMessageComposer.java
Log:
Make thread safe: JBESB-934

Modified: labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/soa/esb/schedule/MockScheduledEventMessageComposer.java
===================================================================
--- labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/soa/esb/schedule/MockScheduledEventMessageComposer.java	2007-08-29 04:30:44 UTC (rev 14720)
+++ labs/jbossesb/trunk/product/rosetta/tests/src/org/jboss/soa/esb/schedule/MockScheduledEventMessageComposer.java	2007-08-29 09:41:13 UTC (rev 14721)
@@ -23,6 +23,7 @@
 import org.jboss.soa.esb.helpers.ConfigTree;
 import org.jboss.soa.esb.message.Message;
 
+import java.util.Collections;
 import java.util.List;
 import java.util.ArrayList;
 
@@ -32,9 +33,9 @@
 public class MockScheduledEventMessageComposer implements ScheduledEventMessageComposer {
 
     public static ConfigTree config;
-    public static boolean uninitialised;
-    public static List<Message> composedMessages = new ArrayList<Message>();
-    public static List<Message> completedMessage = new ArrayList<Message>();
+    public static volatile boolean uninitialised;
+    public static List<Message> composedMessages = Collections.synchronizedList(new ArrayList<Message>());
+    public static List<Message> completedMessage = Collections.synchronizedList(new ArrayList<Message>());
 
     public static void reset() {
         config = null;
@@ -54,7 +55,6 @@
     public Message composeMessage() throws SchedulingException {
         Message message = org.jboss.soa.esb.message.format.MessageFactory.getInstance().getMessage();
         MockScheduledEventMessageComposer.composedMessages.add(message);
-
         return message;
     }