We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent a81ce66 commit 6dce82eCopy full SHA for 6dce82e
src/rabbit_fifo_client.erl
@@ -65,6 +65,9 @@
65
servers = [] :: [ra_server_id()],
66
leader :: maybe(ra_server_id()),
67
next_seq = 0 :: seq(),
68
+ %% Last applied is initialise to -1 to note that no command has yet been
69
+ %% applied, but allowing to resend messages if the first ones on the sequence
70
+ %% are lost (messages are sent from last_applied + 1)
71
last_applied = -1 :: maybe_seq(),
72
next_enqueue_seq = 1 :: seq(),
73
%% indicates that we've exceeded the soft limit
0 commit comments