Make sure autorecovering channels track queues declared with nowait = true

Author: michaelklishin

src/com/rabbitmq/client/impl/recovery/AutorecoveringChannel.java

@@ -250,7 +250,14 @@ public void queueDeclareNowait(String queue,
                                    boolean exclusive,
                                    boolean autoDelete,
                                    Map<String, Object> arguments) throws IOException {
+        RecordedQueue meta = new RecordedQueue(this, queue).
+            durable(durable).
+            exclusive(exclusive).
+            autoDelete(autoDelete).
+            arguments(arguments);
         delegate.queueDeclareNowait(queue, durable, exclusive, autoDelete, arguments);
+        recordQueue(queue, meta);
+
     }
 
     public AMQP.Queue.DeclareOk queueDeclarePassive(String queue) throws IOException {
@@ -501,6 +508,10 @@ private void recordQueue(AMQP.Queue.DeclareOk ok, RecordedQueue q) {
         this.connection.recordQueue(ok, q);
     }
 
+    private void recordQueue(String queue, RecordedQueue meta) {
+        this.connection.recordQueue(queue, meta);
+    }
+
     private void deleteRecordedQueue(String queue) {
         this.connection.deleteRecordedQueue(queue);
     }

src/com/rabbitmq/client/impl/recovery/AutorecoveringConnection.java

@@ -573,6 +573,10 @@ void recordQueue(AMQP.Queue.DeclareOk ok, RecordedQueue q) {
         this.recordedQueues.put(ok.getQueue(), q);
     }
 
+    void recordQueue(String queue, RecordedQueue meta) {
+        this.recordedQueues.put(queue, meta);
+    }
+
     void deleteRecordedQueue(String queue) {
         this.recordedQueues.remove(queue);
     }