diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2012-11-28 12:09:37 +0000 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2012-11-28 12:09:37 +0000 |
| commit | f4786168c90dd2ffa1a4e8a1b54eae1c61e2a7eb (patch) | |
| tree | d970c3af5b58fb2935da60e0996c0822b5a6dbd4 | |
| parent | cc25f470115cfd68e8f474ee9252d1f3eb30ae88 (diff) | |
| download | rabbitmq-server-f4786168c90dd2ffa1a4e8a1b54eae1c61e2a7eb.tar.gz | |
Oops
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index 1ba6774a..11490b9c 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -235,9 +235,9 @@ handle_cast({sync_start, Ref, MPid}, Ref, TRef, MPid, BQ, BQS, fun (BQN, BQSN) -> BQSN1 = update_ram_duration(BQN, BQSN), - TRef = erlang:send_after(?RAM_DURATION_UPDATE_INTERVAL, - self(), update_ram_duration), - {TRef, BQSN1} + TRefN = erlang:send_after(?RAM_DURATION_UPDATE_INTERVAL, + self(), update_ram_duration), + {TRefN, BQSN1} end) of {ok, Res} -> noreply(set_delta(0, S(Res))); %% [0] {failed, Res} -> noreply(S(Res)); %% [1] |