anchor.diff:  			Client ! Reply,
   			Fubar1 = fubar:set([{via, ClientId}, {payload, Reply}], Fubar),
   			{ok, Timer1} = timer:send_after(#?MODULE.retry_after*#?MODULE.max_retries, {retry, MessageId}),
  -			NewState = State#?MODULE{retry_pool=[{MessageId, Fubar1, #?MODULE.max_retries, Timer1} | Pool]},
  -			case State#?MODULE.alert of
  -				true -> {noreply, NewState, hibernate};
  -				false -> {noreply, NewState}
  -			end;
  +			noreply(State#?MODULE{retry_pool=[{MessageId, Fubar1, #?MODULE.max_retries, Timer1} | Pool]});
   		false ->
   			fubar_log:log(warning, ?MODULE, [ClientId, "too late pubrec for", MessageId]),
  -			case State#?MODULE.alert of
  -				true -> {noreply, State, hibernate};
  -				false -> {noreply, State}
  -			end
  +			noreply(State)
   	end;
   handle_info(#mqtt_pubrel{message_id=MessageId}, State=#?MODULE{name=ClientId}) ->
   	case lists:keyfind(MessageId, 1, State#?MODULE.transactions) of
   		false ->
   			fubar_log:log(warning, ?MODULE, [ClientId, "too late pubrel for", MessageId]),
  -			case State#?MODULE.alert of
  -				true -> {noreply, State, hibernate};
  -				false -> {noreply, State}
  -			end;
  +			noreply(State);
   		{MessageId, Worker, _} ->
   			Worker ! release,
  -			case State#?MODULE.alert of
  -				true -> {noreply, State, hibernate};
  -				false -> {noreply, State}
  -			end
  +			noreply(State)
   	end;
   handle_info(#mqtt_pubcomp{message_id=MessageId}, State=#?MODULE{name=ClientId}) ->
   	% The message id is supposed to be in the retry pool.
  
positive.code: %%
  %% Local
  %%
  do_transaction(ClientId, Message=#mqtt_publish{topic=Name}, Trace) ->
  	Props = [{origin, ClientId}, {from, ClientId}, {to, Name}, {via, ClientId}, {payload, Message}],
  	Fubar = case Trace of
  
negative.code: 	F = fun(Topic, Subscriptions) ->
  				lists:keydelete(Topic, 1, Subscriptions)
  		end,
  	noreply(State#?MODULE{subscriptions=lists:foldl(F, State#?MODULE.subscriptions, Topics)});
  handle_info({'EXIT', Client, Reason}, State=#?MODULE{client=Client}) ->
  	fubar_log:log(debug, ?MODULE, [State#?MODULE.name, "client down", Client, Reason]),
  	case State#?MODULE.clean of
  		true ->
  			{stop, normal, State#?MODULE{client=undefined}};
  		_ ->
  			noreply(State#?MODULE{client=undefined})
  	end;
  handle_info({'EXIT', Worker, normal}, State=#?MODULE{name=ClientId}) ->
  	% Likely to be a transaction completion signal.
  