diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-10-04 15:43:46 +0100 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-10-04 15:43:46 +0100 |
| commit | 0273fbe1480005c8364b6fd8ab6f890ab7547f63 (patch) | |
| tree | 56c6b9e2f788834cbba0eeeb99f6304895e06a8e | |
| parent | 3cbbcb57949ec4a29f289596420904aa0f4af694 (diff) | |
| download | rabbitmq-server-0273fbe1480005c8364b6fd8ab6f890ab7547f63.tar.gz | |
gb:add -> gb:insert
| -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 c687ae02..900f325b 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 { |