diff options
| author | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-03-02 13:32:59 +0000 |
|---|---|---|
| committer | Alexandru Scvortov <alexandru@rabbitmq.com> | 2011-03-02 13:32:59 +0000 |
| commit | 69e059a7f5878dafc4751d80811c710d9a48563a (patch) | |
| tree | 0b7417ed51316f069ceda5f9771fea5a825c50cf | |
| parent | 438c93a18a874cbf888aeb0e7766f336caccac15 (diff) | |
| download | rabbitmq-server-git-69e059a7f5878dafc4751d80811c710d9a48563a.tar.gz | |
only confirm delivered messages that need confirming
| -rw-r--r-- | src/rabbit_variable_queue.erl | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/src/rabbit_variable_queue.erl b/src/rabbit_variable_queue.erl index d1307b8527..d0c984cb00 100644 --- a/src/rabbit_variable_queue.erl +++ b/src/rabbit_variable_queue.erl @@ -510,8 +510,13 @@ publish(Msg, MsgProps, State) -> a(reduce_memory_use(State1)). publish_delivered(false, #basic_message { guid = Guid }, - _MsgProps, State = #vqstate { len = 0 }) -> - blind_confirm(self(), gb_sets:singleton(Guid)), + MsgProps = #message_properties { + needs_confirming = NeedsConfirming }, + State = #vqstate { len = 0 }) -> + case NeedsConfirming of + true -> blind_confirm(self(), gb_sets:singleton(Guid)); + false -> ok + end, {undefined, a(State)}; publish_delivered(true, Msg = #basic_message { is_persistent = IsPersistent, guid = Guid }, |