Merge pull request #680 from vikinghawk/consumerRecoveryRetryFix

consumer recovery retry needs to return the new consumer tag
rabbitmq · Apr 2, 2021 · 9b7baa8 · 9b7baa8
2 parents f27a954 + 2d988ee
commit 9b7baa8
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/rabbitmq/client/impl/recovery/TopologyRecoveryRetryLogic.java b/src/main/java/com/rabbitmq/client/impl/recovery/TopologyRecoveryRetryLogic.java
@@ -165,10 +165,11 @@ public abstract class TopologyRecoveryRetryLogic {
                 } else if (consumer.getChannel() == channel) {
                     final RetryContext retryContext = new RetryContext(consumer, context.exception(), context.connection());
                     RECOVER_CONSUMER_QUEUE.call(retryContext);
-                    consumer.recover();
+                    context.connection().recoverConsumer(consumer.getConsumerTag(), consumer, false);
                     RECOVER_CONSUMER_QUEUE_BINDINGS.call(retryContext);
                 }
             }
+            return context.consumer().getConsumerTag();
         }
         return null;
     };