[hornetq-commits] JBoss hornetq SVN: r10158 - branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/jms/server/management.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2011-01-29 00:31:35 -0500 (Sat, 29 Jan 2011)
New Revision: 10158

Modified:
   branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControlUsingJMSTest.java
Log:
tweak

Modified: branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControlUsingJMSTest.java
===================================================================
--- branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControlUsingJMSTest.java	2011-01-28 22:43:41 UTC (rev 10157)
+++ branches/Branch_2_2_EAP/tests/src/org/hornetq/tests/integration/jms/server/management/JMSServerControlUsingJMSTest.java	2011-01-29 05:31:35 UTC (rev 10158)
@@ -20,6 +20,7 @@
 import javax.jms.Session;
 
 import org.hornetq.api.core.TransportConfiguration;
+import org.hornetq.api.core.client.HornetQClient;
 import org.hornetq.api.core.management.ResourceNames;
 import org.hornetq.api.jms.HornetQJMSClient;
 import org.hornetq.api.jms.JMSFactoryType;
@@ -28,6 +29,7 @@
 import org.hornetq.core.security.Role;
 import org.hornetq.jms.client.HornetQConnectionFactory;
 import org.hornetq.jms.client.HornetQQueue;
+import org.hornetq.jms.client.HornetQQueueConnectionFactory;
 
 /**
  * A JMSServerControlUsingCoreTest
@@ -56,7 +58,79 @@
       }
       return names;
    }
-
+   
+   // The JMS test won't support the server being restarted, hence we have to do a slight different test on that case
+   public void testCreateConnectionFactory_CompleteList() throws Exception
+   {
+      JMSServerControl control = createManagementControl();
+      control.createConnectionFactory("test", //name
+                                      true, // ha
+                                      false, // useDiscovery
+                                      1, // cfType
+                                      "invm", // connectorNames
+                                      "tst", // jndiBindins
+                                      "tst", // clientID
+                                      1, // clientFailureCheckPeriod
+                                      1,  // connectionTTL
+                                      1, // callTimeout
+                                      1, // minLargeMessageSize
+                                      true, // compressLargeMessages
+                                      1, // consumerWindowSize
+                                      1, // consumerMaxRate
+                                      1, // confirmationWindowSize
+                                      1, // ProducerWindowSize
+                                      1, // producerMaxRate
+                                      true, // blockOnACK
+                                      true, // blockOnDurableSend
+                                      true, // blockOnNonDurableSend
+                                      true, // autoGroup
+                                      true, // preACK
+                                      HornetQClient.DEFAULT_CONNECTION_LOAD_BALANCING_POLICY_CLASS_NAME, // loadBalancingClassName
+                                      1, // transactionBatchSize
+                                      1, // dupsOKBatchSize
+                                      true, // useGlobalPools
+                                      1, // scheduleThreadPoolSize
+                                      1, // threadPoolMaxSize
+                                      1, // retryInterval
+                                      1, // retryIntervalMultiplier
+                                      1, // maxRetryInterval
+                                      1, // reconnectAttempts
+                                      true, // failoverOnInitialConnection
+                                      "tst"); // groupID
+      
+      
+      HornetQQueueConnectionFactory cf = (HornetQQueueConnectionFactory)context.lookup("tst");
+      
+      assertEquals(true, cf.isHA());
+      assertEquals("tst", cf.getClientID());
+      assertEquals(1, cf.getClientFailureCheckPeriod());
+      assertEquals(1, cf.getConnectionTTL());
+      assertEquals(1, cf.getCallTimeout());
+      assertEquals(1, cf.getMinLargeMessageSize());
+      assertEquals(true, cf.isCompressLargeMessage());
+      assertEquals(1, cf.getConsumerWindowSize());
+      assertEquals(1, cf.getConfirmationWindowSize());
+      assertEquals(1, cf.getProducerWindowSize());
+      assertEquals(1, cf.getProducerMaxRate());
+      assertEquals(true, cf.isBlockOnAcknowledge());
+      assertEquals(true, cf.isBlockOnDurableSend());
+      assertEquals(true, cf.isBlockOnNonDurableSend());
+      assertEquals(true, cf.isAutoGroup());
+      assertEquals(true, cf.isPreAcknowledge());
+      assertEquals(HornetQClient.DEFAULT_CONNECTION_LOAD_BALANCING_POLICY_CLASS_NAME, cf.getConnectionLoadBalancingPolicyClassName());
+      assertEquals(1, cf.getTransactionBatchSize());
+      assertEquals(1, cf.getDupsOKBatchSize());
+      assertEquals(true, cf.isUseGlobalPools());
+      assertEquals(1, cf.getScheduledThreadPoolMaxSize());
+      assertEquals(1, cf.getThreadPoolMaxSize());
+      assertEquals(1, cf.getRetryInterval());
+      assertEquals(1.0, cf.getRetryIntervalMultiplier());
+      assertEquals(1, cf.getMaxRetryInterval());
+      assertEquals(1, cf.getReconnectAttempts());
+      assertEquals(true, cf.isFailoverOnInitialConnection());
+      assertEquals("tst", cf.getGroupID());
+      
+   }
    // Constructors --------------------------------------------------
 
    // JMSServerControlTest overrides --------------------------------