diff options
| -rw-r--r-- | src/rabbit_variable_queue.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index c687ae02bf..900f325bbc 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -542,7 +542,7 @@ publish_delivered(true, Msg = #basic_message { is_persistent = IsPersistent, PA1 = record_pending_ack(m(MsgStatus1), PA), PCount1 = PCount + one_if(IsPersistent1), Unconfirmed1 = case NeedsConfirming of - true -> gb_sets:add(Guid, Unconfirmed); + true -> gb_sets:insert(Guid, Unconfirmed); false -> Unconfirmed end, {SeqId, a(State1 #vqstate { @@ -1068,7 +1068,7 @@ publish(Msg = #basic_message { is_persistent = IsPersistent, end, PCount1 = PCount + one_if(IsPersistent1), Unconfirmed1 = case NeedsConfirming of - true -> gb_sets:add(Guid, Unconfirmed); + true -> gb_sets:insert(Guid, Unconfirmed); false -> Unconfirmed end, {SeqId, State2 #vqstate { |