[infinispan-commits] Infinispan SVN: r929 - trunk/core/src/test/java/org/infinispan/replication.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-10-09 06:43:39 -0400 (Fri, 09 Oct 2009)
New Revision: 929

Modified:
   trunk/core/src/test/java/org/infinispan/replication/ReplicationQueueTest.java
Log:
Updated test

Modified: trunk/core/src/test/java/org/infinispan/replication/ReplicationQueueTest.java
===================================================================
--- trunk/core/src/test/java/org/infinispan/replication/ReplicationQueueTest.java	2009-10-09 07:25:02 UTC (rev 928)
+++ trunk/core/src/test/java/org/infinispan/replication/ReplicationQueueTest.java	2009-10-09 10:43:39 UTC (rev 929)
@@ -12,6 +12,7 @@
 import org.testng.annotations.Test;
 
 import javax.transaction.TransactionManager;
+import java.util.Map;
 import java.util.Properties;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.ScheduledExecutorService;
@@ -239,7 +240,11 @@
       }
 
       public ScheduledExecutorService getScheduledExecutor(Properties p) {
-         assert p.equals(myProps);
+         Properties toCompareWith = new Properties();
+         for (Map.Entry<Object, Object> entry: myProps.entrySet())
+            toCompareWith.setProperty((String) entry.getKey(), (String) entry.getValue()); 
+         toCompareWith.setProperty("componentName", "replicationQueue-thread");
+         assert p.equals(toCompareWith);
          methodCalled = true;
          return new ScheduledThreadPoolExecutor(1) {
             @Override