Permalink
Browse files

Revert "fix consumer_died error"

This reverts commit 6cd8c68.
  • Loading branch information...
1 parent d552e1b commit aed90b652432708718f56ba6f8e3105ae4bd78ec @jlouis jlouis committed Feb 5, 2013
Showing with 1 addition and 5 deletions.
  1. +1 −5 src/amqp_gen_consumer.erl
@@ -229,10 +229,8 @@ handle_call({consumer_call, Method, Args}, _From,
case Return of
{ok, NewMState} ->
{reply, ok, State#state{module_state = NewMState}};
- {error, {consumer_died, Reason}, NewMState} ->
- {stop, Reason, State#state{module_state = NewMState}};
{error, Reason, NewMState} ->
- {stop, {error, Reason},
+ {stop, {error, Reason}, {error, Reason},
State#state{module_state = NewMState}}
end.
@@ -244,8 +242,6 @@ handle_info(Info, State = #state{module_state = MState,
case ConsumerModule:handle_info(Info, MState) of
{ok, NewMState} ->
{noreply, State#state{module_state = NewMState}};
- {error, {consumer_died, Reason}, NewMState} ->
- {stop, Reason, State#state{module_state = NewMState}};
{error, Reason, NewMState} ->
{stop, {error, Reason}, State#state{module_state = NewMState}}
end.

0 comments on commit aed90b6

Please sign in to comment.