diff options
| author | Matthias Radestock <matthias@lshift.net> | 2009-07-24 17:50:54 +0100 |
|---|---|---|
| committer | Matthias Radestock <matthias@lshift.net> | 2009-07-24 17:50:54 +0100 |
| commit | e1e3bab3b85dd8cdcf90cb956ed40ad09cac2296 (patch) | |
| tree | 7fff92ae65a80c2416f4eb79a4f30ca9ad2fa5df | |
| parent | dcafb19d513beeb7b788896b2a6aebff248097e0 (diff) | |
| download | rabbitmq-server-e1e3bab3b85dd8cdcf90cb956ed40ad09cac2296.tar.gz | |
cosmetic
| -rw-r--r-- | src/rabbit_amqqueue_process.erl | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/src/rabbit_amqqueue_process.erl b/src/rabbit_amqqueue_process.erl index 0180d86a..9a9e75d6 100644 --- a/src/rabbit_amqqueue_process.erl +++ b/src/rabbit_amqqueue_process.erl @@ -54,8 +54,7 @@ next_msg_id, message_buffer, active_consumers, - blocked_consumers - }). + blocked_consumers}). -record(consumer, {tag, ack_required}). @@ -102,8 +101,7 @@ init(Q) -> next_msg_id = 1, message_buffer = queue:new(), active_consumers = queue:new(), - blocked_consumers = queue:new() - }, {binary, ?HIBERNATE_AFTER_MIN}}. + blocked_consumers = queue:new()}, {binary, ?HIBERNATE_AFTER_MIN}}. terminate(_Reason, State) -> %% FIXME: How do we cancel active subscriptions? @@ -118,11 +116,9 @@ code_change(_OldVsn, State, _Extra) -> %%---------------------------------------------------------------------------- -reply(Reply, NewState) -> - {reply, Reply, NewState, binary}. +reply(Reply, NewState) -> {reply, Reply, NewState, binary}. -noreply(NewState) -> - {noreply, NewState, binary}. +noreply(NewState) -> {noreply, NewState, binary}. lookup_ch(ChPid) -> case get({ch, ChPid}) of |