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

Author: clebert.suconic(a)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 --------------------------------