reverted changes to QueueExclusivity

Author: Alexandru Scvortov

test/src/com/rabbitmq/client/test/functional/QueueExclusivity.java

@@ -67,7 +67,6 @@ public void testQueueExclusiveForPassiveDeclare() throws Exception {
         try {
             channel.queueDeclarePassive(q);
         } catch (IOException ioe) {
-            checkShutdownSignal(AMQP.RESOURCE_LOCKED, ioe);
             return;
         }
         fail("Passive queue declaration of an exclusive queue from another connection should fail");
@@ -79,7 +78,6 @@ public void testQueueExclusiveForDeclare() throws Exception {
         try {
             channel.queueDeclare(q, false, true, false, noArgs);
         } catch (IOException ioe) {
-            checkShutdownSignal(AMQP.RESOURCE_LOCKED, ioe);
             return;
         }
         fail("Active queue declaration of an exclusive queue from another connection should fail");
@@ -90,7 +88,6 @@ public void testQueueExclusiveForConsume() throws Exception {
         try {
             channel.basicConsume(q, c);
         } catch (IOException ioe) {
-            checkShutdownSignal(AMQP.RESOURCE_LOCKED, ioe);
             return;
         }
         fail("Exclusive queue should be locked for basic consume from another connection");
@@ -100,7 +97,6 @@ public void testQueueExclusiveForPurge() throws Exception {
         try {
             channel.queuePurge(q);
         } catch (IOException ioe) {
-            checkShutdownSignal(AMQP.RESOURCE_LOCKED, ioe);
             return;
         }
         fail("Exclusive queue should be locked for queue purge from another connection");
@@ -110,7 +106,6 @@ public void testQueueExclusiveForDelete() throws Exception {
         try {
             channel.queueDelete(q);
         } catch (IOException ioe) {
-            checkShutdownSignal(AMQP.RESOURCE_LOCKED, ioe);
             return;
         }
         fail("Exclusive queue should be locked for queue delete from another connection");
@@ -120,7 +115,6 @@ public void testQueueExclusiveForBind() throws Exception {
         try {
             channel.queueBind(q, "", ""); // NB uses default exchange
         } catch (IOException ioe) {
-            checkShutdownSignal(AMQP.INTERNAL_ERROR, ioe);
             return;
         }
         fail("Exclusive queue should be locked for queue bind from another connection");
@@ -138,7 +132,6 @@ public void testQueueExclusiveForUnbind() throws Exception {
         try {
             channel.queueUnbind(q, "", "");
         } catch (IOException ioe) {
-            checkShutdownSignal(AMQP.INTERNAL_ERROR, ioe);
             return;
         }
         fail("Exclusive queue should be locked for queue unbind from another connection");
@@ -148,7 +141,6 @@ public void testQueueExclusiveForGet() throws Exception {
         try {
             channel.basicGet(q, true);
         } catch (IOException ioe) {
-            checkShutdownSignal(AMQP.RESOURCE_LOCKED, ioe);
             return;
         }
         fail("Exclusive queue should be locked for basic get from another connection");