[hornetq-commits] JBoss hornetq SVN: r7914 - in trunk/tests: src/org/hornetq/tests/integration/jms and 2 other directories.

Author: clebert.suconic(a)jboss.com Date: 2009-08-25 19:30:51 -0400 (Tue, 25 Aug 2009) New Revision: 7914 Added: trunk/tests/src/org/hornetq/tests/integration/jms/largemessage/ trunk/tests/src/org/hornetq/tests/integration/jms/largemessage/JMSLargeMessageTest.java trunk/tests/src/org/hornetq/tests/util/JMSTestBase.java Removed: trunk/tests/jms-tests/src/org/hornetq/jms/tests/message/LargeMessageTest.java Log: https://jira.jboss.org/jira/browse/HORNETQ-107 - Move JMS test added by accident to integration-tests Deleted: trunk/tests/jms-tests/src/org/hornetq/jms/tests/message/LargeMessageTest.java =================================================================== --- trunk/tests/jms-tests/src/org/hornetq/jms/tests/message/LargeMessageTest.java 2009-08-25 20:13:48 UTC (rev 7913) +++ trunk/tests/jms-tests/src/org/hornetq/jms/tests/message/LargeMessageTest.java 2009-08-25 23:30:51 UTC (rev 7914) @@ -1,371 +0,0 @@ -/* - * Copyright 2009 Red Hat, Inc. - * Red Hat licenses this file to you under the Apache License, version - * 2.0 (the "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * http://www.apache.org/licenses/LICENSE-2.0 - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or - * implied. See the License for the specific language governing - * permissions and limitations under the License. - */ - -package org.hornetq.jms.tests.message; - -import java.io.IOException; -import java.io.InputStream; -import java.io.OutputStream; -import java.util.concurrent.CountDownLatch; -import java.util.concurrent.atomic.AtomicInteger; -import java.util.concurrent.atomic.AtomicLong; - -import javax.jms.BytesMessage; -import javax.jms.Connection; -import javax.jms.JMSException; -import javax.jms.MessageConsumer; -import javax.jms.MessageProducer; -import javax.jms.Session; -import javax.jms.TextMessage; - -import org.hornetq.jms.tests.JMSTestCase; - -/** - * - * @author <a href="mailto:clebert.suconic@feodorov.com">Clebert Suconic</a> - * @version <tt>$Revision: 6220 $</tt> - * - * $Id: MessageHeaderTest.java 6220 2009-03-30 19:38:11Z timfox $ - */ -public class LargeMessageTest extends JMSTestCase -{ - // Constants ----------------------------------------------------- - - // Attributes ---------------------------------------------------- - - // Static -------------------------------------------------------- - - // Constructors -------------------------------------------------- - - // Public -------------------------------------------------------- - - public void testSimpleLargeMessage() throws Exception - { - Connection conn = null; - - try - { - conn = cf.createConnection(); - - Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); - - MessageProducer prod = session.createProducer(queue1); - - BytesMessage m = session.createBytesMessage(); - - m.setObjectProperty("JMS_HQ_InputStream", createFakeLargeStream(1024 * 1024)); - - prod.send(m); - - conn.close(); - - conn = cf.createConnection(); - - session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); - - MessageConsumer cons = session.createConsumer(queue1); - - conn.start(); - - BytesMessage rm = (BytesMessage)cons.receive(10000); - - byte data[] = new byte[1024]; - - System.out.println("Message = " + rm); - - for (int i = 0; i < 1024 * 1024; i += 1024) - { - int numberOfBytes = rm.readBytes(data); - assertEquals(1024, numberOfBytes); - for (int j = 0; j < 1024; j++) - { - assertEquals(getSamplebyte(i + j), data[j]); - } - } - - assertNotNull(rm); - - } - finally - { - if (conn != null) - { - conn.close(); - } - } - - } - - public void testSimpleLargeMessage2() throws Exception - { - Connection conn = null; - - try - { - conn = cf.createConnection(); - - Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); - - MessageProducer prod = session.createProducer(queue1); - - BytesMessage m = session.createBytesMessage(); - - m.setObjectProperty("JMS_HQ_InputStream", createFakeLargeStream(10)); - - prod.send(m); - - conn.close(); - - conn = cf.createConnection(); - - session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); - - MessageConsumer cons = session.createConsumer(queue1); - - conn.start(); - - BytesMessage rm = (BytesMessage)cons.receive(10000); - - byte data[] = new byte[1024]; - - System.out.println("Message = " + rm); - - int numberOfBytes = rm.readBytes(data); - assertEquals(10, numberOfBytes); - for (int j = 0; j < numberOfBytes; j++) - { - assertEquals(getSamplebyte(j), data[j]); - } - - assertNotNull(rm); - - } - finally - { - if (conn != null) - { - conn.close(); - } - } - - } - - public void testExceptionsOnSettingNonStreaming() throws Exception - { - Connection conn = null; - - try - { - conn = cf.createConnection(); - - Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); - - TextMessage msg = session.createTextMessage(); - - try - { - msg.setObjectProperty("JMS_HQ_InputStream", createFakeLargeStream(10)); - fail("Exception was expected"); - } - catch (JMSException e) - { - } - - msg.setText("hello"); - - MessageProducer prod = session.createProducer(queue1); - - prod.send(msg); - - conn.close(); - - conn = cf.createConnection(); - - session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); - - MessageConsumer cons = session.createConsumer(queue1); - - conn.start(); - - TextMessage rm = (TextMessage)cons.receive(10000); - - try - { - rm.setObjectProperty("JMS_HQ_OutputStream", new OutputStream() - { - @Override - public void write(int b) throws IOException - { - System.out.println("b = " + b); - } - - }); - fail("Exception was expected"); - } - catch (JMSException e) - { - } - - - assertEquals("hello", rm.getText()); - - assertNotNull(rm); - - } - finally - { - if (conn != null) - { - conn.close(); - } - } - - } - - public void testWaitOnOutputStream() throws Exception - { - int msgSize = 1024 * 1024; - - Connection conn = null; - - try - { - conn = cf.createConnection(); - - Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); - - MessageProducer prod = session.createProducer(queue1); - - BytesMessage m = session.createBytesMessage(); - - m.setObjectProperty("JMS_HQ_InputStream", createFakeLargeStream(msgSize)); - - prod.send(m); - - conn.close(); - - conn = cf.createConnection(); - - session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); - - MessageConsumer cons = session.createConsumer(queue1); - - conn.start(); - - BytesMessage rm = (BytesMessage)cons.receive(10000); - assertNotNull(rm); - - final AtomicLong numberOfBytes = new AtomicLong(0); - - final AtomicInteger numberOfErrors = new AtomicInteger(0); - - OutputStream out = new OutputStream() - { - - int position = 0; - - @Override - public void write(int b) throws IOException - { - numberOfBytes.incrementAndGet(); - if (getSamplebyte(position++) != b) - { - System.out.println("Wrong byte at position " + position); - numberOfErrors.incrementAndGet(); - } - } - - }; - - rm.setObjectProperty("JMS_HQ_SaveStream", out); - - assertEquals(msgSize, numberOfBytes.get()); - - assertEquals(0, numberOfErrors.get()); - - } - finally - { - if (conn != null) - { - conn.close(); - } - } - - } - - // Package protected --------------------------------------------- - - // Protected ----------------------------------------------------- - - protected byte getSamplebyte(final long position) - { - return (byte)('a' + (position) % ('z' - 'a' + 1)); - } - - // Creates a Fake LargeStream without using a real file - protected InputStream createFakeLargeStream(final long size) throws Exception - { - return new InputStream() - { - private long count; - - private boolean closed = false; - - @Override - public void close() throws IOException - { - super.close(); - System.out.println("Sent " + count + " bytes over fakeOutputStream, while size = " + size); - closed = true; - } - - @Override - public int read() throws IOException - { - if (closed) - { - throw new IOException("Stream was closed"); - } - if (count++ < size) - { - return getSamplebyte(count - 1); - } - else - { - return -1; - } - } - }; - - } - - // Private ------------------------------------------------------- - - // Inner classes ------------------------------------------------- - - class ThreadReader extends Thread - { - CountDownLatch latch; - - ThreadReader(CountDownLatch latch) - { - this.latch = latch; - } - - public void run() - { - } - } - -} Copied: trunk/tests/src/org/hornetq/tests/integration/jms/largemessage/JMSLargeMessageTest.java (from rev 7912, trunk/tests/jms-tests/src/org/hornetq/jms/tests/message/LargeMessageTest.java) =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/jms/largemessage/JMSLargeMessageTest.java (rev 0) +++ trunk/tests/src/org/hornetq/tests/integration/jms/largemessage/JMSLargeMessageTest.java 2009-08-25 23:30:51 UTC (rev 7914) @@ -0,0 +1,352 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ + +package org.hornetq.tests.integration.jms.largemessage; + +import java.io.IOException; +import java.io.InputStream; +import java.io.OutputStream; +import java.util.concurrent.CountDownLatch; +import java.util.concurrent.atomic.AtomicInteger; +import java.util.concurrent.atomic.AtomicLong; + +import javax.jms.BytesMessage; +import javax.jms.Connection; +import javax.jms.JMSException; +import javax.jms.MessageConsumer; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.Session; +import javax.jms.TextMessage; + +import org.hornetq.jms.tests.JMSTestCase; +import org.hornetq.tests.util.JMSTestBase; + +/** + * + * @author <a href="mailto:clebert.suconic@feodorov.com">Clebert Suconic</a> + * @version <tt>$Revision: 6220 $</tt> + * + * $Id: MessageHeaderTest.java 6220 2009-03-30 19:38:11Z timfox $ + */ +public class JMSLargeMessageTest extends JMSTestBase +{ + // Constants ----------------------------------------------------- + + // Attributes ---------------------------------------------------- + + Queue queue1; + + // Static -------------------------------------------------------- + + // Constructors -------------------------------------------------- + + // Public -------------------------------------------------------- + + protected boolean usePersistence() + { + return true; + } + + protected void setUp() throws Exception + { + super.setUp(); + serverManager.createQueue("queue1", "/jms/queue1", null, true); + + queue1 = (Queue)context.lookup("/jms/queue1"); + } + + protected void tearDown() throws Exception + { + queue1 = null; + super.tearDown(); + } + + public void testSimpleLargeMessage() throws Exception + { + Connection conn = null; + + try + { + conn = cf.createConnection(); + + Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + + MessageProducer prod = session.createProducer(queue1); + + BytesMessage m = session.createBytesMessage(); + + m.setObjectProperty("JMS_HQ_InputStream", createFakeLargeStream(1024 * 1024)); + + prod.send(m); + + conn.close(); + + conn = cf.createConnection(); + + session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + + MessageConsumer cons = session.createConsumer(queue1); + + conn.start(); + + BytesMessage rm = (BytesMessage)cons.receive(10000); + + byte data[] = new byte[1024]; + + System.out.println("Message = " + rm); + + for (int i = 0; i < 1024 * 1024; i += 1024) + { + int numberOfBytes = rm.readBytes(data); + assertEquals(1024, numberOfBytes); + for (int j = 0; j < 1024; j++) + { + assertEquals(getSamplebyte(i + j), data[j]); + } + } + + assertNotNull(rm); + + } + finally + { + if (conn != null) + { + conn.close(); + } + } + + } + + public void testSimpleLargeMessage2() throws Exception + { + Connection conn = null; + + try + { + conn = cf.createConnection(); + + Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + + MessageProducer prod = session.createProducer(queue1); + + BytesMessage m = session.createBytesMessage(); + + m.setObjectProperty("JMS_HQ_InputStream", createFakeLargeStream(10)); + + prod.send(m); + + conn.close(); + + conn = cf.createConnection(); + + session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + + MessageConsumer cons = session.createConsumer(queue1); + + conn.start(); + + BytesMessage rm = (BytesMessage)cons.receive(10000); + + byte data[] = new byte[1024]; + + System.out.println("Message = " + rm); + + int numberOfBytes = rm.readBytes(data); + assertEquals(10, numberOfBytes); + for (int j = 0; j < numberOfBytes; j++) + { + assertEquals(getSamplebyte(j), data[j]); + } + + assertNotNull(rm); + + } + finally + { + if (conn != null) + { + conn.close(); + } + } + + } + + public void testExceptionsOnSettingNonStreaming() throws Exception + { + Connection conn = null; + + try + { + conn = cf.createConnection(); + + Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + + TextMessage msg = session.createTextMessage(); + + try + { + msg.setObjectProperty("JMS_HQ_InputStream", createFakeLargeStream(10)); + fail("Exception was expected"); + } + catch (JMSException e) + { + } + + msg.setText("hello"); + + MessageProducer prod = session.createProducer(queue1); + + prod.send(msg); + + conn.close(); + + conn = cf.createConnection(); + + session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + + MessageConsumer cons = session.createConsumer(queue1); + + conn.start(); + + TextMessage rm = (TextMessage)cons.receive(10000); + + try + { + rm.setObjectProperty("JMS_HQ_OutputStream", new OutputStream() + { + @Override + public void write(int b) throws IOException + { + System.out.println("b = " + b); + } + + }); + fail("Exception was expected"); + } + catch (JMSException e) + { + } + + + assertEquals("hello", rm.getText()); + + assertNotNull(rm); + + } + finally + { + if (conn != null) + { + conn.close(); + } + } + + } + + public void testWaitOnOutputStream() throws Exception + { + int msgSize = 1024 * 1024; + + Connection conn = null; + + try + { + conn = cf.createConnection(); + + Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + + MessageProducer prod = session.createProducer(queue1); + + BytesMessage m = session.createBytesMessage(); + + m.setObjectProperty("JMS_HQ_InputStream", createFakeLargeStream(msgSize)); + + prod.send(m); + + conn.close(); + + conn = cf.createConnection(); + + session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE); + + MessageConsumer cons = session.createConsumer(queue1); + + conn.start(); + + BytesMessage rm = (BytesMessage)cons.receive(10000); + assertNotNull(rm); + + final AtomicLong numberOfBytes = new AtomicLong(0); + + final AtomicInteger numberOfErrors = new AtomicInteger(0); + + OutputStream out = new OutputStream() + { + + int position = 0; + + @Override + public void write(int b) throws IOException + { + numberOfBytes.incrementAndGet(); + if (getSamplebyte(position++) != b) + { + System.out.println("Wrong byte at position " + position); + numberOfErrors.incrementAndGet(); + } + } + + }; + + rm.setObjectProperty("JMS_HQ_SaveStream", out); + + assertEquals(msgSize, numberOfBytes.get()); + + assertEquals(0, numberOfErrors.get()); + + } + finally + { + if (conn != null) + { + conn.close(); + } + } + + } + + // Package protected --------------------------------------------- + + // Protected ----------------------------------------------------- + + // Private ------------------------------------------------------- + + // Inner classes ------------------------------------------------- + + class ThreadReader extends Thread + { + CountDownLatch latch; + + ThreadReader(CountDownLatch latch) + { + this.latch = latch; + } + + public void run() + { + } + } + +} Added: trunk/tests/src/org/hornetq/tests/util/JMSTestBase.java =================================================================== --- trunk/tests/src/org/hornetq/tests/util/JMSTestBase.java (rev 0) +++ trunk/tests/src/org/hornetq/tests/util/JMSTestBase.java 2009-08-25 23:30:51 UTC (rev 7914) @@ -0,0 +1,206 @@ +/* + * Copyright 2009 Red Hat, Inc. + * Red Hat licenses this file to you under the Apache License, version + * 2.0 (the "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * http://www.apache.org/licenses/LICENSE-2.0 + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + * implied. See the License for the specific language governing + * permissions and limitations under the License. + */ + +package org.hornetq.tests.util; + +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_ACK_BATCH_SIZE; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_AUTO_GROUP; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_BLOCK_ON_ACKNOWLEDGE; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_BLOCK_ON_NON_PERSISTENT_SEND; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_BLOCK_ON_PERSISTENT_SEND; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_CACHE_LARGE_MESSAGE_CLIENT; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_CLIENT_FAILURE_CHECK_PERIOD; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_CONNECTION_LOAD_BALANCING_POLICY_CLASS_NAME; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_CONNECTION_TTL; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_CONSUMER_MAX_RATE; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_CONSUMER_WINDOW_SIZE; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_MAX_CONNECTIONS; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_MIN_LARGE_MESSAGE_SIZE; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_PRE_ACKNOWLEDGE; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_PRODUCER_MAX_RATE; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_PRODUCER_WINDOW_SIZE; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_THREAD_POOL_MAX_SIZE; +import static org.hornetq.core.client.impl.ClientSessionFactoryImpl.DEFAULT_USE_GLOBAL_POOLS; + +import java.util.ArrayList; +import java.util.List; + +import javax.jms.ConnectionFactory; + +import org.hornetq.core.config.Configuration; +import org.hornetq.core.config.TransportConfiguration; +import org.hornetq.core.server.HornetQ; +import org.hornetq.core.server.HornetQServer; +import org.hornetq.integration.transports.netty.NettyAcceptorFactory; +import org.hornetq.integration.transports.netty.NettyConnectorFactory; +import org.hornetq.jms.server.impl.JMSServerManagerImpl; +import org.hornetq.tests.unit.util.InVMContext; +import org.hornetq.utils.Pair; + +/** + * A JMSBaseTest + * + * @author <mailto:clebert.suconic@jboss.org">Clebert Suconic</a> + * + * + */ +public class JMSTestBase extends ServiceTestBase +{ + + protected HornetQServer server; + + protected JMSServerManagerImpl serverManager; + + protected ConnectionFactory cf; + + protected InVMContext context; + + // Static -------------------------------------------------------- + + // Attributes ---------------------------------------------------- + + // Constructors -------------------------------------------------- + + // TestCase overrides ------------------------------------------- + + // Public -------------------------------------------------------- + + // Package protected --------------------------------------------- + + // Protected ----------------------------------------------------- + + protected boolean useSecurity() + { + return false; + } + + protected boolean useJMX() + { + return true; + } + + protected boolean usePersistence() + { + return false; + } + + @Override + protected void setUp() throws Exception + { + super.setUp(); + + Configuration conf = createDefaultConfig(false); + conf.setSecurityEnabled(false); + conf.setJMXManagementEnabled(true); + + conf.getAcceptorConfigurations().add(new TransportConfiguration(NettyAcceptorFactory.class.getName())); + + server = HornetQ.newHornetQServer(conf, false); + + serverManager = new JMSServerManagerImpl(server); + context = new InVMContext(); + serverManager.setContext(context); + serverManager.start(); + serverManager.activated(); + + registerConnectionFactory(); + } + + protected void restartServer() throws Exception + { + serverManager.start(); + serverManager.activated(); + context = new InVMContext(); + serverManager.setContext(context); + registerConnectionFactory(); + } + + protected void killServer() throws Exception + { + serverManager.stop(); + } + + @Override + protected void tearDown() throws Exception + { + + serverManager.stop(); + + server.stop(); + + context.close(); + + server = null; + + serverManager = null; + + context = null; + + super.tearDown(); + } + + // Private ------------------------------------------------------- + + // Inner classes ------------------------------------------------- + + private void registerConnectionFactory() throws Exception + { + int retryInterval = 1000; + double retryIntervalMultiplier = 1.0; + int reconnectAttempts = -1; + boolean failoverOnServerShutdown = true; + int callTimeout = 30000; + + List<Pair<TransportConfiguration, TransportConfiguration>> connectorConfigs = new ArrayList<Pair<TransportConfiguration, TransportConfiguration>>(); + connectorConfigs.add(new Pair<TransportConfiguration, TransportConfiguration>(new TransportConfiguration(NettyConnectorFactory.class.getName()), + null)); + + List<String> jndiBindings = new ArrayList<String>(); + jndiBindings.add("/cf"); + + serverManager.createConnectionFactory("ManualReconnectionToSingleServerTest", + connectorConfigs, + null, + DEFAULT_CLIENT_FAILURE_CHECK_PERIOD, + DEFAULT_CONNECTION_TTL, + callTimeout, + DEFAULT_MAX_CONNECTIONS, + DEFAULT_CACHE_LARGE_MESSAGE_CLIENT, + DEFAULT_MIN_LARGE_MESSAGE_SIZE, + DEFAULT_CONSUMER_WINDOW_SIZE, + DEFAULT_CONSUMER_MAX_RATE, + DEFAULT_PRODUCER_WINDOW_SIZE, + DEFAULT_PRODUCER_MAX_RATE, + DEFAULT_BLOCK_ON_ACKNOWLEDGE, + DEFAULT_BLOCK_ON_PERSISTENT_SEND, + DEFAULT_BLOCK_ON_NON_PERSISTENT_SEND, + DEFAULT_AUTO_GROUP, + DEFAULT_PRE_ACKNOWLEDGE, + DEFAULT_CONNECTION_LOAD_BALANCING_POLICY_CLASS_NAME, + DEFAULT_ACK_BATCH_SIZE, + DEFAULT_ACK_BATCH_SIZE, + DEFAULT_USE_GLOBAL_POOLS, + DEFAULT_SCHEDULED_THREAD_POOL_MAX_SIZE, + DEFAULT_THREAD_POOL_MAX_SIZE, + retryInterval, + retryIntervalMultiplier, + reconnectAttempts, + failoverOnServerShutdown, + jndiBindings); + + cf = (ConnectionFactory)context.lookup("/cf"); + + } + +}