[hornetq-commits] JBoss hornetq SVN: r9530 - trunk/tests/src/org/hornetq/tests/integration/ra.

[do-not-reply at jboss.org]

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 at 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();