anchor.diff:                                     Processes
                              end
                      end,
  -    {ok, ok, State#state{rpc_processes = NewProcesses,
  -                         cbauth_info = Info}}.
  -
  +    {noreply, State#state{rpc_processes = NewProcesses,
  +                          cbauth_info = Info}}.
  +
  +handle_info(maybe_notify_cbauth, State) ->
  +    misc:flush(maybe_notify_cbauth),
  +    {noreply, maybe_notify_cbauth(State)};
   handle_info({'DOWN', MRef, _, Pid, Reason},
               #state{rpc_processes = Processes} = State) ->
       {value, {MRef, Label}, NewProcesses} = lists:keytake(MRef, 1, Processes),
       ?log_debug("Observed json rpc process ~p died with reason ~p", [{Label, Pid}, Reason]),
  -    {ok, State#state{rpc_processes = NewProcesses}};
  +    {noreply, State#state{rpc_processes = NewProcesses}};
   
   handle_info(_Info, State) ->
  -    {ok, State}.
  +    {noreply, State}.
   
   maybe_notify_cbauth(#state{rpc_processes = Processes,
                              cbauth_info = CBAuthInfo} = State) ->
  
positive.code: -include("ns_common.hrl").
  
  start_link() ->
      misc:start_event_link(fun () ->
                                    gen_event:add_sup_handler(ns_config_events, ?MODULE, [])
                            end).
  
  init([]) ->
      ns_pubsub:subscribe_link(json_rpc_events, fun json_rpc_event/1),
      ns_pubsub:subscribe_link(ns_node_disco_events, fun node_disco_event/1),
      json_rpc_connection:reannounce(),
      {ok, #state{}}.
  
  json_rpc_event(Event) ->
      gen_event:call(ns_config_events, ?MODULE, Event).
  
  node_disco_event(Event) ->
      gen_event:call(ns_config_events, ?MODULE, Event).
  
  terminate(_Reason, _State)     -> ok.
  code_change(_OldVsn, State, _) -> {ok, State}.
  
negative.code: is_interesting({read_only_user_creds, _}) -> true;
  is_interesting(_) -> false.
  
  handle_call(_Msg, _From, State) ->
      {reply, not_implemented, State}.
  
  handle_cast({Msg, Label, Pid}, #state{rpc_processes = Processes,
                                        cbauth_info = CBAuthInfo} = State) ->
      ?log_debug("Observed json rpc process ~p ~p", [{Label, Pid}, Msg]),
      Info = case CBAuthInfo of
  