anchor.diff:      lists:foreach(
           fun(SpaceId) ->
               CurrentSeq = get_current_seq(SpaceId),
  -%%            ?info("DBSync broadcast for space ~p: ~p", [SpaceId, CurrentSeq]),
  +            ?info("DBSync broadcast for space ~p: ~p", [SpaceId, CurrentSeq]),
               {ok, Providers} = oz_spaces:get_providers(provider, SpaceId),
               dbsync_proto:status_report(SpaceId, Providers -- [oneprovider:get_provider_id()], CurrentSeq)
           end, SpaceIds).
  
positive.code:     pong;
  
  handle(healthcheck) ->
      case state_get(changes_stream) of
          Stream when is_pid(Stream) ->
              ok;
  
negative.code: %% Push changes from queue to providers
  handle({flush_queue, QueueKey}) ->
      ?debug("[ DBSync ] Flush queue ~p", [QueueKey]),
      ensure_global_stream_active(),
      state_update({queue, QueueKey},
          fun(#queue{batch_map = BatchMap, removed = IsRemoved} = Queue) ->
              NewBatchMap = maps:map(
  