summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorSimon MacMullen <simon@rabbitmq.com>2014-08-07 15:03:13 +0100
committerSimon MacMullen <simon@rabbitmq.com>2014-08-07 15:03:13 +0100
commitfca7c2fce7cf89fb4f91de93a16d8560b08fd10a (patch)
treed0fe5b7e1872b5367585f75bdc3557d44ca7623a /src
parentfd99a8c5554e235255c4820f474ecc6c5f2812eb (diff)
downloadrabbitmq-server-git-fca7c2fce7cf89fb4f91de93a16d8560b08fd10a.tar.gz
A case missed in bug 26204.
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_mirror_queue_slave.erl4
1 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_mirror_queue_slave.erl b/src/rabbit_mirror_queue_slave.erl
index cc06ae442d..6d0064abe7 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);