Skip to content

Commit 596526a

Browse files
Recover state after listeners
1 parent 57b0792 commit 596526a

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -407,11 +407,11 @@ public void automaticallyRecover(AutorecoveringConnection connection, Connection
407407
this.connection = connection;
408408
this.delegate = (RecoveryAwareChannelN) connDelegate.createChannel(this.getChannelNumber());
409409
this.delegate.inheritOffsetFrom(defunctChannel);
410-
this.recoverState();
411410

412411
this.recoverReturnListeners();
413412
this.recoverConfirmListeners();
414413
this.recoverFlowListeners();
414+
this.recoverState();
415415
this.notifyRecoveryListeners();
416416
}
417417

0 commit comments

Comments
 (0)