anchor.diff:              Pid = spawn_link(fun() -> ok end),
               {ok, Pid};
           state_based ->
  -            %% Naive anti-entropy mechanism; re-broadcast all messages.
  -            gen_server:call(?MODULE, {exchange, Peer}, infinity)
  +            case lasp_config:get(broadcast, false) of
  +                true ->
  +                    %% Plumtree AAE.
  +                    gen_server:call(?MODULE, {exchange, Peer}, infinity);
  +                false ->
  +                    %% No AAE through this mechanism.
  +                    %%
  +                    %% Spawn a process that terminates immediately, because the
  +                    %% broadcast exchange timer tracks the number of in progress
  +                    %% exchanges and bounds it by that limit.
  +                    %%
  +                    Pid = spawn_link(fun() -> ok end),
  +                    {ok, Pid}
  +            end
       end.
   
   %%%===================================================================
  
positive.code:     {reply, ok, State}.
  
  -spec handle_cast(term(), #state{}) -> {noreply, #state{}}.
  %% Anti-entropy mechanism for causal consistency of delta-CRDT;
  %% periodically ship delta-interval or entire state.
  handle_cast({exchange, Peer}, #state{store=Store, gc_counter=GCCounter}=State) ->
      lager:info("Exchange starting for ~p", [Peer]),
  
      Function = fun({Id, #dv{value=Value, type=Type, metadata=Metadata,
  
negative.code:                end,
      spawn_link(fun() -> do(fold, [Store, Function, []]) end),
  
      {noreply, State#state{gc_counter=increment_counter(GCCounter)}};
  
  handle_cast({aae_send, From, {Id, Type, _Metadata, Value}},
              #state{store=Store, actor=Actor}=State) ->
      lager:info("Received incoming state: ~p ~p", [Id, Value]),
      ?CORE:receive_value(Store, {aae_send,
                                  From,
                                 {Id, Type, _Metadata, Value},
  