Author: jmesnil Date: 2010-08-12 09:54:32 -0400 (Thu, 12 Aug 2010) New Revision: 9530 Modified: trunk/tests/src/org/hornetq/tests/integration/ra/OutgoingConnectionTest.java Log: Resource Adapter test * make sure to stop the RA in teardown() Modified: trunk/tests/src/org/hornetq/tests/integration/ra/OutgoingConnectionTest.java =================================================================== --- trunk/tests/src/org/hornetq/tests/integration/ra/OutgoingConnectionTest.java 2010-08-11 14:43:33 UTC (rev 9529) +++ trunk/tests/src/org/hornetq/tests/integration/ra/OutgoingConnectionTest.java 2010-08-12 13:54:32 UTC (rev 9530) @@ -12,27 +12,42 @@ */ package org.hornetq.tests.integration.ra; -import org.hornetq.api.core.client.HornetQClient; +import java.util.HashSet; +import java.util.Set; + +import javax.jms.IllegalStateException; +import javax.jms.JMSException; +import javax.jms.Message; +import javax.jms.MessageConsumer; +import javax.jms.MessageProducer; +import javax.jms.Queue; +import javax.jms.QueueConnection; +import javax.jms.Session; +import javax.jms.TextMessage; +import javax.jms.XAQueueConnection; +import javax.jms.XASession; +import javax.transaction.xa.XAResource; +import javax.transaction.xa.Xid; + import org.hornetq.api.jms.HornetQJMSClient; import org.hornetq.core.remoting.impl.invm.InVMConnectorFactory; import org.hornetq.core.security.Role; import org.hornetq.core.transaction.impl.XidImpl; -import org.hornetq.ra.*; +import org.hornetq.ra.HornetQRAConnectionFactory; +import org.hornetq.ra.HornetQRAConnectionFactoryImpl; +import org.hornetq.ra.HornetQRAConnectionManager; +import org.hornetq.ra.HornetQRAManagedConnectionFactory; +import org.hornetq.ra.HornetQResourceAdapter; import org.hornetq.utils.UUIDGenerator; -import javax.jms.*; -import javax.jms.IllegalStateException; -import javax.transaction.xa.XAResource; -import javax.transaction.xa.Xid; -import java.util.HashSet; -import java.util.Set; - /** * @author <a href="mailto:andy.taylor@jboss.org">Andy Taylor</a> * Created Jul 7, 2010 */ public class OutgoingConnectionTest extends HornetQRATestBase { + private HornetQResourceAdapter resourceAdapter; + @Override public boolean isSecure() { @@ -53,16 +68,25 @@ roles.add(role); server.getSecurityRepository().addMatch(MDBQUEUEPREFIXED, roles); } + + @Override + protected void tearDown() throws Exception + { + if (resourceAdapter != null) + { + resourceAdapter.stop(); + } + } public void testSimpleMessageSendAndReceive() throws Exception { - HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter(); - qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); + resourceAdapter = new HornetQResourceAdapter(); + resourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); MyBootstrapContext ctx = new MyBootstrapContext(); - qResourceAdapter.start(ctx); + resourceAdapter.start(ctx); HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager(); HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory(); - mcf.setResourceAdapter(qResourceAdapter); + mcf.setResourceAdapter(resourceAdapter); HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager); QueueConnection queueConnection = qraConnectionFactory.createQueueConnection(); Session s = queueConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); @@ -81,13 +105,13 @@ public void testSimpleMessageSendAndReceiveXA() throws Exception { Xid xid = new XidImpl("xa1".getBytes(), 1, UUIDGenerator.getInstance().generateStringUUID().getBytes()); - HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter(); - qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); + resourceAdapter = new HornetQResourceAdapter(); + resourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); MyBootstrapContext ctx = new MyBootstrapContext(); - qResourceAdapter.start(ctx); + resourceAdapter.start(ctx); HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager(); HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory(); - mcf.setResourceAdapter(qResourceAdapter); + mcf.setResourceAdapter(resourceAdapter); HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager); XAQueueConnection queueConnection = qraConnectionFactory.createXAQueueConnection(); XASession s = queueConnection.createXASession(); @@ -111,18 +135,20 @@ assertNotNull(textMessage); assertEquals(textMessage.getText(), "test"); s.close(); + + resourceAdapter.stop(); } public void testSimpleMessageSendAndReceiveTransacted() throws Exception { - HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter(); - qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); - qResourceAdapter.setUseLocalTx(true); + resourceAdapter = new HornetQResourceAdapter(); + resourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); + resourceAdapter.setUseLocalTx(true); MyBootstrapContext ctx = new MyBootstrapContext(); - qResourceAdapter.start(ctx); + resourceAdapter.start(ctx); HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager(); HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory(); - mcf.setResourceAdapter(qResourceAdapter); + mcf.setResourceAdapter(resourceAdapter); HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager); QueueConnection queueConnection = qraConnectionFactory.createQueueConnection(); Session s = queueConnection.createSession(true, Session.AUTO_ACKNOWLEDGE); @@ -146,13 +172,13 @@ public void testMultipleSessionsThrowsException() throws Exception { - HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter(); - qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); + resourceAdapter = new HornetQResourceAdapter(); + resourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); MyBootstrapContext ctx = new MyBootstrapContext(); - qResourceAdapter.start(ctx); + resourceAdapter.start(ctx); HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager(); HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory(); - mcf.setResourceAdapter(qResourceAdapter); + mcf.setResourceAdapter(resourceAdapter); HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager); QueueConnection queueConnection = qraConnectionFactory.createQueueConnection(); Session s = queueConnection.createSession(false, Session.AUTO_ACKNOWLEDGE); @@ -170,13 +196,13 @@ public void testConnectionCredentials() throws Exception { - HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter(); - qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); + resourceAdapter = new HornetQResourceAdapter(); + resourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); MyBootstrapContext ctx = new MyBootstrapContext(); - qResourceAdapter.start(ctx); + resourceAdapter.start(ctx); HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager(); HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory(); - mcf.setResourceAdapter(qResourceAdapter); + mcf.setResourceAdapter(resourceAdapter); HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager); QueueConnection queueConnection = qraConnectionFactory.createQueueConnection(); queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE).close(); @@ -187,13 +213,13 @@ public void testConnectionCredentialsFail() throws Exception { - HornetQResourceAdapter qResourceAdapter = new HornetQResourceAdapter(); - qResourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); + resourceAdapter = new HornetQResourceAdapter(); + resourceAdapter.setConnectorClassName(InVMConnectorFactory.class.getName()); MyBootstrapContext ctx = new MyBootstrapContext(); - qResourceAdapter.start(ctx); + resourceAdapter.start(ctx); HornetQRAConnectionManager qraConnectionManager = new HornetQRAConnectionManager(); HornetQRAManagedConnectionFactory mcf = new HornetQRAManagedConnectionFactory(); - mcf.setResourceAdapter(qResourceAdapter); + mcf.setResourceAdapter(resourceAdapter); HornetQRAConnectionFactory qraConnectionFactory = new HornetQRAConnectionFactoryImpl(mcf, qraConnectionManager); QueueConnection queueConnection = qraConnectionFactory.createQueueConnection(); queueConnection.createQueueSession(false, Session.AUTO_ACKNOWLEDGE).close();