diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-12-19 13:40:31 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-12-19 13:40:31 +0000 |
| commit | a9bf1aea60ec2e78bac8c226b248ac28c8eabe49 (patch) | |
| tree | cfb89e52cf2d847317b1c47d73e14d63552f7ae9 | |
| parent | b9dbac16a49924b0abf4fceb3e0f7034a19b75c8 (diff) | |
| download | rabbitmq-server-git-a9bf1aea60ec2e78bac8c226b248ac28c8eabe49.tar.gz | |
fix msg_store losing confirms
| -rw-r--r-- | src/rabbit_msg_store.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_msg_store.erl b/src/rabbit_msg_store.erl index e8b4e8e270..2e1834c796 100644 --- a/src/rabbit_msg_store.erl +++ b/src/rabbit_msg_store.erl @@ -701,7 +701,7 @@ handle_cast({write, CRef, Guid}, {ok, _} -> dict:update(CRef, fun(Guids) -> gb_sets:add(Guid, Guids) end, - gb_sets:empty(), CTG); + gb_sets:singleton(Guid), CTG); error -> CTG end, State1 = State #msstate { cref_to_guids = CTG1 }, |