diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-11-23 16:33:30 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-11-23 16:33:30 +0000 |
| commit | c0b8d853327b6a066bed78c8723f470a4bf9027e (patch) | |
| tree | 8dcff3a46f5aaaefa9640ee1aad79d90e594c237 /src | |
| parent | 90d9c7cf87012a919ee8115f11017c1febf99381 (diff) | |
| download | rabbitmq-server-git-c0b8d853327b6a066bed78c8723f470a4bf9027e.tar.gz | |
Cosmetic / clearer.
Diffstat (limited to 'src')
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index cd2b205c56..ae069898d7 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -840,7 +840,7 @@ record_synchronised(#amqqueue { name = QName }) -> end). sync_loop(Ref, MRef, State = #state{backing_queue = BQ, - backing_queue_state = BQS}) -> + backing_queue_state = BQS}) -> receive {'DOWN', MRef, process, _MPid, _Reason} -> %% If the master dies half way we are not in the usual @@ -854,11 +854,10 @@ sync_loop(Ref, MRef, State = #state{backing_queue = BQ, erlang:demonitor(MRef), set_delta(0, State); {sync_message, Ref, M} -> - %% TODO expiry / delivered need fixing + %% TODO expiry needs fixing Props = #message_properties{expiry = undefined, needs_confirming = false, - delivered = false}, + delivered = true}, BQS1 = BQ:publish(M, Props, none, BQS), sync_loop(Ref, MRef, State#state{backing_queue_state = BQS1}) end. - |