summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/rabbit_amqqueue_process.erl2
-rw-r--r--src/rabbit_channel.erl2
2 files changed, 2 insertions, 2 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl
index cce937192f..30e3e234b8 100644
--- a/src/rabbit_amqqueue_process.erl
+++ b/src/rabbit_amqqueue_process.erl
@@ -848,7 +848,7 @@ handle_cast({set_maximum_since_use, Age}, State) ->
handle_cast(emit_stats, State) ->
emit_stats(State),
- noreply(State#q{stats_timer_ref = undefined}).
+ noreply(State).
handle_info({'DOWN', _MonitorRef, process, DownPid, _Reason},
State = #q{q = #amqqueue{exclusive_owner = DownPid}}) ->
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl
index 6a1c40a662..3c5111cfe5 100644
--- a/src/rabbit_channel.erl
+++ b/src/rabbit_channel.erl
@@ -272,7 +272,7 @@ handle_cast({flow_timeout, _Ref}, State) ->
handle_cast(emit_stats, State) ->
internal_emit_stats(State),
- noreply(State#ch{stats_timer_ref = undefined}).
+ noreply(State).
handle_info({'EXIT', WriterPid, Reason = {writer, send_failed, _Error}},
State = #ch{writer_pid = WriterPid}) ->