anchor.diff:      true = ets:insert(?MODULE, {Id, Message}),
   
       %% Forward to random subset of peers.
  -    AntiEntropyMembers = select_random_sublist(membership(Membership), ?GOSSIP_FANOUT),
  +    AntiEntropyMembers = select_random_sublist(membership(Membership), ?FANOUT),
   
       lists:foreach(fun(N) ->
  -        Manager:forward_message(N, ?GOSSIP_CHANNEL, ?MODULE, {broadcast, Id, ServerRef, Message, MyNode}, [])
  +        partisan_pluggable_peer_service_manager:forward_message(N, undefined, ?MODULE, {broadcast, Id, ServerRef, Message, MyNode}, [])
       end, AntiEntropyMembers -- [MyNode]),
   
  -    {noreply, State};
  +    {noreply, State#state{next_id=NextId + 1}};
   
   handle_cast({update, Membership0}, State) ->
       Membership = membership(Membership0),
       {noreply, State#state{membership=Membership}};
   
   handle_cast(Msg, State) ->
  -    lager:warning("Unhandled cast messages at module ~p: ~p", [?MODULE, Msg]),
  +    partisan_logger:warning("Unhandled cast messages at module ~p: ~p", [?MODULE, Msg]),
       {noreply, State}.
   
   %% @private
   %% Incoming messages.
   handle_info({broadcast, Id, ServerRef, Message, FromNode}, #state{membership=Membership}=State) ->
  -    lager:info("~p received broadcast value from node ~p: ~p", [node(), FromNode, Message]),
  +    partisan_logger:info("~p received broadcast value from node ~p: ~p", [node(), FromNode, Message]),
   
       case ets:lookup(?MODULE, Id) of
           [] ->
  
positive.code:          terminate/2,
           code_change/3]).
  
  -record(state, {membership}).
  
  %%%===================================================================
  %%% API
  
negative.code: 
      %% Start with initial membership.
      {ok, Membership} = partisan_peer_service:members(),
      partisan_logger:info("Starting with membership: ~p", [Membership]),
  
      {ok, #state{next_id=0, membership=membership(Membership)}}.
  
  %% @private
  handle_call(Msg, _From, State) ->
      partisan_logger:warning("Unhandled call messages at module ~p: ~p", [?MODULE, Msg]),
      {reply, ok, State}.
  
  %% @private
  handle_cast({broadcast, ServerRef, Message}, #state{next_id=NextId, membership=Membership}=State) ->
      %% Generate message id.
      MyNode = partisan_peer_service_manager:mynode(),
      Id = {MyNode, NextId},
  
      %% Forward to process.
      partisan_util:process_forward(ServerRef, Message),
  