sync call from process with many incoming msgs
replicate() ->
    {ok, Token} = db:ask_replicate(...),
    receive
       {replication_completed, Token} ->
             ok
    end