anchor.diff:      {change, Change} ->
         collect_changes(I-1, queue:in(Change, Q))
     after 5000 ->
  -					lager:notice("Queue on Timeout ~p", [Q]),
  -					{error, timeout}
  -							%collect_changes(0, queue:in({error, timeout}, Q))
  +          lager:notice("Queue on Timeout ~p", [Q]),
  +          {error, timeout}
  +              %collect_changes(0, queue:in({error, timeout}, Q))
     end.
   
   wait_pids([]) -> ok;
  
positive.code: 
  all() ->
    [
      collect_change,
      include_doc,
      collect_changes,
      changes_feed_callback,
      heartbeat_collect_change,
      heartbeat_and_timeout,
    	multiple_put,
      restart_when_server_timeout
    ].
  
  init_per_suite(Config) ->
  
negative.code:   {ok, <<"bb">>, _} = barrel_httpc:post(db(Config), Doc2, []),
  
  
    receive
        {change, #{ <<"seq">> := 2, <<"id">> := <<"bb">>}}  ->
            ok
    after 5000 ->
            lager:notice("Seq 2 timeout",[]),
            throw(timeout)
    end,
  
  
    receive {change, #{ <<"seq">> := 1, <<"id">> := Val}} ->
            ok;
            _E ->
            lager:notice("Recived 1 ~p",[_E])
    after 5000 ->
            lager:notice("Seq 1 timeout",[]),
            throw(timeout)
    end,
    %% ok = case collect_changes(2, queue:new()) of
    %%           [
    %%            #{ <<"seq">> := 1, <<"id">> := Val},
    %%            #{ <<"seq">> := 2, <<"id">> := <<"bb">>}
    %%           ] -> ok;
    %%        _E ->
    %%            lager:info("Returned ~p~n",[_E]),
    %%            false
    %%    end,
    ok = application:stop(barrel_rest),
    {error, timeout} = collect_changes(1, queue:new()),
    ok = barrel_httpc_changes:stop(Pid),
  