Author: ritchiem
Date: Wed Mar 19 05:50:53 2008
New Revision: 638816
URL: http://svn.apache.org/viewvc?rev=638816&view=rev
Log:
QPID-841 : SimpleACLTest didn't close a client connection
Modified:
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
Modified:
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
URL:
http://svn.apache.org/viewvc/incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java?rev=638816&r1=638815&r2=638816&view=diff
==============================================================================
---
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
(original)
+++
incubator/qpid/branches/M2.1/java/systests/src/main/java/org/apache/qpid/server/security/acl/SimpleACLTest.java
Wed Mar 19 05:50:53 2008
@@ -160,6 +160,7 @@
sesh.createConsumer(sesh.createQueue("IllegalQueue"));
fail("Test failed as consumer was created.");
+ //conn will be automatically closed
}
catch (JMSException e)
{
@@ -207,6 +208,7 @@
((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 @@
sesh.createConsumer(sesh.createQueue("Invalid"));
fail("Test failed as consumer was created.");
+ //conn will be automatically closed
}
catch (JMSException e)
{
@@ -374,6 +377,7 @@
sesh.createConsumer(sesh.createTemporaryQueue());
fail("Test failed as consumer was created.");
+ //conn will be automatically closed
}
catch (JMSException e)
{
@@ -420,6 +424,7 @@
((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 @@
true, false, false);
fail("Test failed as creation succeded.");
+ //conn will be automatically closed
}
catch (AMQAuthenticationException amqe)
{
@@ -520,6 +526,7 @@
assertNotNull("Client did not receive response message,",
clientResponseMsg);
assertEquals("Incorrect message received", "Response",
((TextMessage) clientResponseMsg).getText());
+ clientConnection.close();
}
catch (Exception e)
{
