Skip to content

Commit bf657f5

Browse files
author
Simon MacMullen
committed
Don't add message id to the set of msgs we've heard of from gm but not channel, if we actually *have* heard of it from the channel.
1 parent 73a3104 commit bf657f5

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/rabbit_mirror_queue_slave.erl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -725,7 +725,7 @@ process_instruction(
725725
never ->
726726
{MQ2, PendingCh, MS};
727727
eventually ->
728-
{MQ2, sets:add_element(MsgId, PendingCh),
728+
{MQ2, PendingCh,
729729
dict:store(MsgId, {published, ChPid, MsgSeqNo}, MS)};
730730
immediately ->
731731
ok = rabbit_channel:confirm(ChPid, [MsgSeqNo]),

0 commit comments

Comments
 (0)