[hornetq-commits] JBoss hornetq SVN: r8986 - trunk/tests/src/org/hornetq/tests/integration/persistence.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-03-28 16:32:11 -0400 (Sun, 28 Mar 2010)
New Revision: 8986

Modified:
   trunk/tests/src/org/hornetq/tests/integration/persistence/JMSConnectionFactoryConfigurationStorageTest.java
Log:
adding test

Modified: trunk/tests/src/org/hornetq/tests/integration/persistence/JMSConnectionFactoryConfigurationStorageTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/persistence/JMSConnectionFactoryConfigurationStorageTest.java	2010-03-28 20:16:02 UTC (rev 8985)
+++ trunk/tests/src/org/hornetq/tests/integration/persistence/JMSConnectionFactoryConfigurationStorageTest.java	2010-03-28 20:32:11 UTC (rev 8986)
@@ -67,14 +67,18 @@
    {
 
       createJMSStorage();
-
-      String str[] = new String[5];
-      for (int i = 0; i < 5; i++)
+      
+      List<Pair<TransportConfiguration, TransportConfiguration>> transportConfigs = new ArrayList<Pair<TransportConfiguration, TransportConfiguration>>();
+      
+      for (int i = 0 ; i < 5; i++)
       {
-         str[i] = "str" + i;
+         TransportConfiguration config1 = new TransportConfiguration("c1-" + i);
+         TransportConfiguration config2 = new TransportConfiguration("c2-" + i);
+         transportConfigs.add(new Pair<TransportConfiguration, TransportConfiguration>(config1, config2));
       }
+      
 
-      ConnectionFactoryConfiguration config = new ConnectionFactoryConfigurationImpl("some-name", str);
+      ConnectionFactoryConfiguration config = new ConnectionFactoryConfigurationImpl("some-name", transportConfigs);
 
       addSetting(new PersistedConnectionFactory(config));
 
@@ -87,12 +91,18 @@
       assertEquals(1, cfs.size());
 
       assertEquals("some-name", cfs.get(0).getName());
-
-      assertEquals(5, cfs.get(0).getConfig().getBindings().length);
-
-      for (int i = 0; i < 5; i++)
+      
+      PersistedConnectionFactory cf1 = cfs.get(0);
+      
+      assertEquals(5, cf1.getConfig().getConnectorConfigs().size());
+      
+      int i = 0 ;
+      for (Pair<TransportConfiguration, TransportConfiguration> itemCf : cf1.getConfig().getConnectorConfigs())
       {
-         assertEquals("str" + i, cfs.get(0).getConfig().getBindings()[i]);
+         
+         assertEquals(itemCf.a.toString(), "c1-" + i);
+         assertEquals(itemCf.b.toString(), "c2-" + i);
+         i++;
       }
    }