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 | 06ad8fde700795a99363410a41ee1875ec491191 (patch) | |
| tree | d970c3af5b58fb2935da60e0996c0822b5a6dbd4 | |
| parent | 7e349890ba327d634d5771fff6ea3877f03f802d (diff) | |
| download | rabbitmq-server-git-06ad8fde700795a99363410a41ee1875ec491191.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 1ba6774a40..11490b9ca0 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] |