diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-11-08 11:27:24 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-11-08 11:27:24 +0000 |
| commit | f4b9b0114a467b8edab326be43212a857b1dc05d (patch) | |
| tree | 262fa3023335649b9589fc804ad079bd923742f5 /src/rabbit_queue_index.erl | |
| parent | d87631580658864e7212765a640617594c7e53d0 (diff) | |
| download | rabbitmq-server-f4b9b0114a467b8edab326be43212a857b1dc05d.tar.gz | |
confirm messages on queue purge
Diffstat (limited to 'src/rabbit_queue_index.erl')
| -rw-r--r-- | src/rabbit_queue_index.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_queue_index.erl b/src/rabbit_queue_index.erl index 8a4bb801..f61707cc 100644 --- a/src/rabbit_queue_index.erl +++ b/src/rabbit_queue_index.erl @@ -191,7 +191,7 @@ })). -type(seq_id() :: integer()). -type(seg_dict() :: {dict:dictionary(), [segment()]}). --type(on_sync_fun() :: fun (([rabbit_guid:guid()]) -> ok)). +-type(on_sync_fun() :: fun ((gb_set()) -> ok)). -type(qistate() :: #qistate { dir :: file:filename(), segments :: 'undefined' | seg_dict(), journal_handle :: hdl(), @@ -717,7 +717,7 @@ deliver_or_ack(Kind, SeqIds, State) -> end, State1, SeqIds)). notify_sync(State = #qistate { unsynced_guids = UG, on_sync = OnSyncFun }) -> - OnSyncFun(UG), + OnSyncFun(gb_sets:from_list(UG)), State #qistate { unsynced_guids = [] }. %%---------------------------------------------------------------------------- |