diff options
Diffstat (limited to 'src/rabbit_reader_queue_collector.erl')
| -rw-r--r-- | src/rabbit_reader_queue_collector.erl | 20 |
1 files changed, 9 insertions, 11 deletions
diff --git a/src/rabbit_reader_queue_collector.erl b/src/rabbit_reader_queue_collector.erl index 058affa7..841549e9 100644 --- a/src/rabbit_reader_queue_collector.erl +++ b/src/rabbit_reader_queue_collector.erl @@ -47,8 +47,8 @@ -ifdef(use_specs). -spec(start_link/0 :: () -> {'ok', pid()}). --spec(register_exclusive_queue/2 :: (pid(), pid()) -> {'ok'}). --spec(delete_all/1 :: (pid()) -> {'ok'}). +-spec(register_exclusive_queue/2 :: (pid(), amqqueue()) -> 'ok'). +-spec(delete_all/1 :: (pid()) -> 'ok'). -endif. @@ -82,12 +82,12 @@ handle_call({register_exclusive_queue, Q}, _From, handle_call(delete_all, _From, State = #state{exclusive_queues = ExclusiveQueues}) -> [rabbit_misc:with_exit_handler( - fun() -> ok end, - fun() -> - erlang:demonitor(MonitorRef), - rabbit_amqqueue:delete(Q, false, false) - end) - || {MonitorRef, Q} <- dict:to_list(ExclusiveQueues)], + fun() -> ok end, + fun() -> + erlang:demonitor(MonitorRef), + rabbit_amqqueue:delete(Q, false, false) + end) + || {MonitorRef, Q} <- dict:to_list(ExclusiveQueues)], {reply, ok, State}; handle_call(shutdown, _From, State) -> @@ -99,12 +99,10 @@ handle_cast(_Msg, State) -> handle_info({'DOWN', MonitorRef, process, _DownPid, _Reason}, State = #state{exclusive_queues = ExclusiveQueues}) -> {noreply, State#state{exclusive_queues = - dict:erase(MonitorRef, ExclusiveQueues)}}. + dict:erase(MonitorRef, ExclusiveQueues)}}. terminate(_Reason, _State) -> ok. code_change(_OldVsn, State, _Extra) -> {ok, State}. - -%%-------------------------------------------------------------------- |