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 | e14431f715a1edcc9a2b5df1757b4bd574c11196 (patch) | |
| tree | 7fff92ae65a80c2416f4eb79a4f30ca9ad2fa5df /src | |
| parent | 57e0a3be3fa973db550f917c9c88a3a2b4a22f2a (diff) | |
| download | rabbitmq-server-git-e14431f715a1edcc9a2b5df1757b4bd574c11196.tar.gz | |
cosmetic
Diffstat (limited to 'src')
| -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 0180d86ac3..9a9e75d6ca 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 |