Restart primary node app instead of secondary node.

Author: Steve Powell

src/com/rabbitmq/client/impl/ValueWriter.java

@@ -107,7 +107,7 @@ public final void writeTable(Map<String, Object> table)
             out.writeInt(0);
         } else {
             out.writeInt((int)Frame.tableSize(table));
-            for(Map.Entry<String,Object> entry:  table.entrySet()) {
+            for(Map.Entry<String,Object> entry: table.entrySet()) {
                 writeShortstr(entry.getKey());
                 Object value = entry.getValue();
                 writeFieldValue(value);

test/src/com/rabbitmq/client/test/server/ExclusiveQueueDurability.java

@@ -18,12 +18,9 @@
 package com.rabbitmq.client.test.server;
 
 import java.io.IOException;
-import java.util.HashMap;
 
 import com.rabbitmq.client.AMQP;
 import com.rabbitmq.client.Channel;
-import com.rabbitmq.client.Connection;
-import com.rabbitmq.client.ConnectionFactory;
 import com.rabbitmq.client.test.BrokerTestCase;
 import com.rabbitmq.tools.Host;
 
@@ -32,63 +29,30 @@
  * (following the scenarios given in bug 20578).
  */
 public class ExclusiveQueueDurability extends BrokerTestCase {
-    private Channel secondaryChannel;
-    private Connection secondaryConnection;
 
-	HashMap<String, Object> noArgs = new HashMap<String, Object>();
-
-	void verifyQueueMissing(Channel channel, String queueName)
-	        throws IOException {
+    void verifyQueueMissing(Channel channel, String queueName)
+            throws IOException {
         try {
-            channel.queueDeclare(queueName, false, false, false, null);
+            channel.queueDeclare(queueName, true, true, false, null);
         } catch (IOException ioe) {
             checkShutdownSignal(AMQP.RESOURCE_LOCKED, ioe);
             fail("Declaring the queue resulted in a channel exception, probably meaning that it already exists");
         }
     }
 
-    @Override
-    protected void createResources() throws IOException {
-        super.createResources();
-        openChannel();
-
-    }
-
-    // TODO extract some commonality between this and DurableBindingLifecycle
-    public void openChannel()
-        throws IOException
-    {
-        Host.executeCommand("cd ../rabbitmq-test; make restart-secondary-node");
-        ConnectionFactory cf2 = connectionFactory.clone();
-        cf2.setHost("localhost");
-        cf2.setPort(5673);
-        secondaryConnection = cf2.newConnection();
-        secondaryChannel = secondaryConnection.createChannel();
-    }
-
-    @Override
-    protected void releaseResources() throws IOException {
-        secondaryChannel.abort();
-        secondaryChannel = null;
-        secondaryConnection.abort();
-        secondaryConnection = null;
-        super.releaseResources();
-    }
-
     // 1) connection and queue are on same node, node restarts -> queue
     // should no longer exist
     public void testConnectionQueueSameNode() throws Exception {
-        secondaryChannel.queueDeclare("scenario1", true, true, false, noArgs);
-        restartAbruptly();
-        verifyQueueMissing(secondaryChannel, "scenario1");
+        channel.queueDeclare("scenario1", true, true, false, null);
+        restartPrimaryAbruptly();
+        verifyQueueMissing(channel, "scenario1");
     }
 
-    protected void restartAbruptly() throws IOException {
-        secondaryConnection.abort();
-        secondaryConnection = null;
-        secondaryChannel = null;
-        Host.executeCommand("cd ../rabbitmq-test; make restart-secondary-node");
-        openChannel();
+    private void restartPrimaryAbruptly() throws IOException {
+        connection = null;
+        channel = null;
+        Host.executeCommand("cd ../rabbitmq-test; make restart-app");
+        setUp();
     }
 
     /*

test/src/com/rabbitmq/client/test/server/MessageRecovery.java

@@ -24,7 +24,7 @@ public class MessageRecovery extends ConfirmBase
 
     private final static String Q = "recovery-test";
 
-    public void test() throws IOException, InterruptedException {
+    public void testMessageRecovery() throws IOException, InterruptedException {
         channel.queueDeclare(Q, true, false, false, null);
         publish("", Q, true, false, false);
         waitAcks();