summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMartin Ritchie <ritchiem@apache.org>2008-03-19 12:50:53 +0000
committerMartin Ritchie <ritchiem@apache.org>2008-03-19 12:50:53 +0000
commit32e5443fed43625c0f95a36321bf465b2896e19a (patch)
treeded54712511bcd9e87cd744c089c2e56411eff59
parente1a13849b0f1a27b09071e29980aca044fa21f51 (diff)
downloadqpid-python-32e5443fed43625c0f95a36321bf465b2896e19a.tar.gz
QPID-841 : SimpleACLTest didn't close a client connection
git-svn-id: https://svn.apache.org/repos/asf/incubator/qpid/branches/M2.1@638816 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java7
1 files changed, 7 insertions, 0 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java b/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
index 2660b79622..9ba0f6024c 100644
--- a/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
+++ b/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
@@ -160,6 +160,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
sesh.createConsumer(sesh.createQueue("IllegalQueue"));
fail("Test failed as consumer was created.");
+ //conn will be automatically closed
}
catch (JMSException e)
{
@@ -207,6 +208,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
((AMQSession) sesh).createQueue(new AMQShortString("IllegalQueue"), false, false, false);
fail("Test failed as Queue creation succeded.");
+ //conn will be automatically closed
}
catch (AMQAuthenticationException amqe)
{
@@ -348,6 +350,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
sesh.createConsumer(sesh.createQueue("Invalid"));
fail("Test failed as consumer was created.");
+ //conn will be automatically closed
}
catch (JMSException e)
{
@@ -374,6 +377,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
sesh.createConsumer(sesh.createTemporaryQueue());
fail("Test failed as consumer was created.");
+ //conn will be automatically closed
}
catch (JMSException e)
{
@@ -420,6 +424,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
((AMQSession) sesh).createQueue(new AMQShortString("IllegalQueue"), false, false, false);
fail("Test failed as creation succeded.");
+ //conn will be automatically closed
}
catch (AMQAuthenticationException amqe)
{
@@ -441,6 +446,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
true, false, false);
fail("Test failed as creation succeded.");
+ //conn will be automatically closed
}
catch (AMQAuthenticationException amqe)
{
@@ -520,6 +526,7 @@ public class SimpleACLTest extends TestCase implements ConnectionListener
assertNotNull("Client did not receive response message,", clientResponseMsg);
assertEquals("Incorrect message received", "Response", ((TextMessage) clientResponseMsg).getText());
+ clientConnection.close();
}
catch (Exception e)
{