diff options
| author | Emile Joubert <emile@lshift.net> | 2010-05-12 15:52:33 +0100 |
|---|---|---|
| committer | Emile Joubert <emile@lshift.net> | 2010-05-12 15:52:33 +0100 |
| commit | ceeb2d3809e949d2c742af116a48bddf653aceb2 (patch) | |
| tree | cb0a303e626a4c7647ceba730f8f87c2813b9877 | |
| parent | dfe29746b64ef1b263c970a308162ec6ea82cf46 (diff) | |
| download | rabbitmq-server-ceeb2d3809e949d2c742af116a48bddf653aceb2.tar.gz | |
Register memory alarm after channel open
| -rw-r--r-- | src/rabbit_channel.erl | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index 1f16ec08..a48db9c8 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -138,7 +138,6 @@ info_all(Items) -> init([Channel, ReaderPid, WriterPid, Username, VHost]) -> process_flag(trap_exit, true), link(WriterPid), - rabbit_alarm:register(self(), {?MODULE, conserve_memory, []}), ok = pg_local:join(rabbit_channels, self()), {ok, #ch{state = starting, channel = Channel, @@ -353,6 +352,7 @@ queue_blocked(QPid, State = #ch{blocking = Blocking}) -> end. handle_method(#'channel.open'{}, _, State = #ch{state = starting}) -> + rabbit_alarm:register(self(), {?MODULE, conserve_memory, []}), {reply, #'channel.open_ok'{}, State#ch{state = running}}; handle_method(#'channel.open'{}, _, _State) -> |