Skip to content

Commit 28938a3

Browse files
author
Emile Joubert
committed
Merged bug24578 into default
2 parents 38af545 + bf657f5 commit 28938a3

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)