Merge pull request #696 from wangqiandeniangniang/main_friendly_tips

refactor:

Author: michaelklishin

src/main/java/com/rabbitmq/client/impl/recovery/RecordedEntity.java

@@ -20,7 +20,7 @@
 /**
  * @since 3.3.0
  */
-public class RecordedEntity {
+public  abstract class RecordedEntity {
     protected final AutorecoveringChannel channel;
 
     public RecordedEntity(AutorecoveringChannel channel) {

src/main/java/com/rabbitmq/client/impl/recovery/RecordedExchange.java

@@ -31,6 +31,7 @@ public RecordedExchange(AutorecoveringChannel channel, String name) {
         super(channel, name);
     }
 
+    @Override
     public void recover() throws IOException {
         this.channel.getDelegate().exchangeDeclare(this.name, this.type, this.durable, this.autoDelete, this.arguments);
     }

src/main/java/com/rabbitmq/client/impl/recovery/RecordedNamedEntity.java

@@ -15,17 +15,20 @@
 
 package com.rabbitmq.client.impl.recovery;
 
+import java.io.IOException;
 /**
  * @since 3.3.0
  */
-public class RecordedNamedEntity extends RecordedEntity {
+public abstract class RecordedNamedEntity extends RecordedEntity {
     protected String name;
 
     public RecordedNamedEntity(AutorecoveringChannel channel, String name) {
         super(channel);
         this.name = name;
     }
 
+    public abstract void recover() throws IOException;
+
     public String getName() {
         return name;
     }

src/main/java/com/rabbitmq/client/impl/recovery/RecordedQueue.java

@@ -55,6 +55,7 @@ public boolean isServerNamed() {
         return this.serverNamed;
     }
 
+    @Override
     public void recover() throws IOException {
         this.name = this.channel.getDelegate().queueDeclare(this.getNameToUseForRecovery(),
                                                      this.durable,
@@ -71,7 +72,7 @@ public RecordedQueue durable(boolean value) {
         this.durable = value;
         return this;
     }
-    
+
     public boolean isDurable() {
         return this.durable;
     }
@@ -80,7 +81,7 @@ public RecordedQueue autoDelete(boolean value) {
         this.autoDelete = value;
         return this;
     }
-    
+
     public boolean isAutoDelete() {
         return this.autoDelete;
     }

src/main/java/com/rabbitmq/client/impl/recovery/RecordedQueueBinding.java

@@ -27,7 +27,7 @@ public RecordedQueueBinding(AutorecoveringChannel channel) {
 
     @Override
     public void recover() throws IOException {
-        this.channel.getDelegate().queueBind(this.getDestination(), this.getSource(), this.routingKey, this.arguments);
+        this.channel.getDelegate().queueBind(this.destination, this.source, this.routingKey, this.arguments);
     }
 
     @Override