anchor.diff:  
   %% Push changes from queue to providers
   handle({flush_queue, QueueKey}) ->
  -    try
  -    ?info("[ DBSync ] Flush queue ~p", [QueueKey]),
  +    ?debug("[ DBSync ] Flush queue ~p", [QueueKey]),
       ensure_global_stream_active(),
  -    ?info("[ DBSync ] Flush queue2 ~p", [QueueKey]),
       Ans = state_update({queue, QueueKey},
           fun(#queue{batch_map = BatchMap, removed = IsRemoved, until = QUntil} = Queue) ->
  -            ?info("[ DBSync ] mmmmm2 ~p", [{QueueKey, BatchMap}]),
               OldSeq = case state_get(global_resume_seq) of
                            undefined -> 0;
                            OS -> OS
  
positive.code:                     Queue#queue{batch_map = NewBatchMap}
              end;
              (undefined) when QueueKey =:= global ->
                  ?info("[ DBSync ] mmmmm ~p", [QueueKey]),
                  timer:send_after(?FLUSH_QUEUE_INTERVAL, whereis(dbsync_worker), {timer, {flush_queue, QueueKey}}),
                  undefined;
              (undefined) ->
                  ?warning("Unknown operation on empty queue ~p", [QueueKey]),
                  undefined
          end),
      ?info("[ DBSync ] Flush queue4 ~p", [{QueueKey, Ans}]),
      Ans
      catch
          E1:E2 ->
              ?info("[ DBSync ] Flush queue3 ~p", [{QueueKey, E1,E2}]),
              throw(E2)
      end ;
  
  %% Handle external dbsync requests
  handle({dbsync_request, SessId, DBSyncRequest}) ->
  
negative.code: %%--------------------------------------------------------------------
  -spec state_put(Key :: term(), Value :: term()) -> ok.
  state_put(Key, Value) ->
      {ok, _} = dbsync_state:save(#document{key = Key, value = #dbsync_state{entry = Value}}),
      ok.
  
  %%--------------------------------------------------------------------
  