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 | 96c73ecef38f5801a72f3fc5f3c563c1ffb36807 (patch) | |
| tree | 56c6b9e2f788834cbba0eeeb99f6304895e06a8e /src | |
| parent | 4f7984cc8c35fbe512883ff2bc1784690607d679 (diff) | |
| download | rabbitmq-server-git-96c73ecef38f5801a72f3fc5f3c563c1ffb36807.tar.gz | |
gb:add -> gb:insert
Diffstat (limited to 'src')
| -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 { |