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 | 17613c33f42e7608fe7bbbe9d08834cf52f87a85 (patch) | |
| tree | cb0a303e626a4c7647ceba730f8f87c2813b9877 /src | |
| parent | 5ea720eb963451955b8e57c807a47952dbafa6ce (diff) | |
| download | rabbitmq-server-git-17613c33f42e7608fe7bbbe9d08834cf52f87a85.tar.gz | |
Register memory alarm after channel open
Diffstat (limited to 'src')
| -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 1f16ec080e..a48db9c8b3 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) -> |