diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-12-20 16:18:38 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2010-12-20 16:18:38 +0000 |
| commit | e3b89abb4e2071e98c9f3cd514ea29c6cb0b9307 (patch) | |
| tree | ec991c6f00b4855352a8892e3abaa0b84325be0c /src/rabbit_variable_queue.erl | |
| parent | 5fd5dc40a1e1f4176f13cf568c3fa0caaece1cc7 (diff) | |
| download | rabbitmq-server-e3b89abb4e2071e98c9f3cd514ea29c6cb0b9307.tar.gz | |
the msg_store is now responsible for confirming messages
Diffstat (limited to 'src/rabbit_variable_queue.erl')
| -rw-r--r-- | src/rabbit_variable_queue.erl | 6 |
1 files changed, 1 insertions, 5 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index 85216dfc..6264255b 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -656,11 +656,7 @@ internal_fetch(AckRequired, MsgStatus = #msg_status { ack(AckTags, State) -> {Guids, State1} = ack(fun msg_store_remove/3, - fun ({_IsPersistent, Guid, _MsgProps}, State1) -> - remove_confirms(gb_sets:singleton(Guid), State1); - (#msg_status{msg = #basic_message { guid = Guid }}, State1) -> - remove_confirms(gb_sets:singleton(Guid), State1) - end, + fun (_, State0) -> State0 end, AckTags, State), {Guids, a(State1)}. |