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 | 2c3551b53abb929c0ca67885a671b5fb95e77442 (patch) | |
| tree | cfb89e52cf2d847317b1c47d73e14d63552f7ae9 | |
| parent | 5ee7b8f4b4391de0ac9d8bd95ac1fc8358c2040d (diff) | |
| download | rabbitmq-server-2c3551b53abb929c0ca67885a671b5fb95e77442.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 e8b4e8e2..2e1834c7 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 }, |