diff options
| author | Simon MacMullen <simon@rabbitmq.com> | 2014-08-07 15:03:13 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@rabbitmq.com> | 2014-08-07 15:03:13 +0100 |
| commit | b1e49a90d554f857a9874a5ab38fe3f5a9996e47 (patch) | |
| tree | d0fe5b7e1872b5367585f75bdc3557d44ca7623a | |
| parent | 62467ca12d8d3e4c1bd41a41aa22fc5a94180c2e (diff) | |
| download | rabbitmq-server-bug26326.tar.gz | |
A case missed in bug 26204.bug26326
| -rw-r--r-- | src/rabbit_mirror_queue_slave.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl index cc06ae44..6d0064ab 100644 --- a/src/rabbit_mirror_queue_slave.erl +++ b/src/rabbit_mirror_queue_slave.erl @@ -271,8 +271,8 @@ handle_cast({sync_start, Ref, Syncer}, DD, Ref, TRef, Syncer, BQ, BQS, fun (BQN, BQSN) -> BQSN1 = update_ram_duration(BQN, BQSN), - TRefN = erlang:send_after(?RAM_DURATION_UPDATE_INTERVAL, - self(), update_ram_duration), + TRefN = rabbit_misc:send_after(?RAM_DURATION_UPDATE_INTERVAL, + self(), update_ram_duration), {TRefN, BQSN1} end) of denied -> noreply(State1); |