From 4c315330f0acf00dbab36d7c17f1ed3373182388 Mon Sep 17 00:00:00 2001
From: Martin Ritchie <ritchiem@apache.org>
Date: Tue, 7 Nov 2006 13:36:47 +0000
Subject: Added attempt to unbind if an error occurs.

git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/trunk/qpid@472108 13f79535-47bb-0310-9956-ffa450edef68
---
 .../org/apache/qpid/transacted/TransactedTest.java | 23 +++++++++++++---------
 1 file changed, 14 insertions(+), 9 deletions(-)

(limited to 'java/client/test/src')

diff --git a/java/client/test/src/org/apache/qpid/transacted/TransactedTest.java b/java/client/test/src/org/apache/qpid/transacted/TransactedTest.java
index 8b2c930a36..3b102f5373 100644
--- a/java/client/test/src/org/apache/qpid/transacted/TransactedTest.java
+++ b/java/client/test/src/org/apache/qpid/transacted/TransactedTest.java
@@ -30,6 +30,7 @@ import org.junit.Before;
 import org.junit.Test;
 import org.junit.Assert;
 import org.junit.BeforeClass;
+import org.junit.AfterClass;
 
 import javax.jms.*;
 
@@ -53,13 +54,7 @@ public class TransactedTest
     private MessageConsumer testConsumer2;
 
     @BeforeClass
-    public static void setupVM()
-    {
-        System.setProperty("amqj.NoAutoCreateVMBroker", "true");
-    }
-
-    @Before
-    public void setup() throws Exception
+    public static void setupBeforeClass()
     {
         try
         {
@@ -69,6 +64,18 @@ public class TransactedTest
         {
             Assert.fail("Unable to create VM Broker: " + e.getMessage());
         }
+    }
+
+    @AfterClass
+    public static void setupAfterClass()
+    {
+        TransportConnection.killVMBroker(1);
+    }
+
+    @Before
+    public void setup() throws Exception
+    {
+
 
         queue1 = new AMQQueue("Q1", false);
         queue2 = new AMQQueue("Q2", false);
@@ -115,8 +122,6 @@ public class TransactedTest
         con.close();
         testCon.close();
         prepCon.close();
-
-        TransportConnection.killVMBroker(1);
     }
 
     @Test
-- 
cgit v1.2.1