File tree Expand file tree Collapse file tree 1 file changed +9
-1
lines changed Expand file tree Collapse file tree 1 file changed +9
-1
lines changed Original file line number Diff line number Diff line change @@ -71,7 +71,15 @@ public interface Consumer {
7171 void handleShutdownSignal (String consumerTag , ShutdownSignalException sig );
7272
7373 /**
74- * Called when the
74+ * Called to notify the consumer that we've received a basic.recover-ok
75+ * in reply to a basic.recover some other thread sent. All messages
76+ * received before this is invoked that haven't been ack'ed will be
77+ * redelivered. All messages received afterwards won't be.
78+ *
79+ * This method exists since all the Consumer callbacks are invoked by the
80+ * connection main loop thread - so it's sometimes useful to allow that
81+ * thread to know that the recover-ok has been received, rather than the
82+ * thread which invoked basicRecover().
7583 */
7684 void handleRecoverOk ();
7785
You can’t perform that action at this time.
0 commit comments