anchor.diff:      shift(Now, Rest).
   
   update_item(Key, UpdateOp) ->
  -    ok.
  -    %% try
  -    %%     ets:update_counter(?TABLE, Key, UpdateOp)
  -    %% catch error:badarg -> error
  -    %% end.
  +    try
  +        ets:update_counter(?TABLE, Key, UpdateOp)
  +    catch error:badarg -> error
  +    end.
   
   averages([], Acc) -> Acc;
   averages([{Key, counter}|Rest], Acc) ->
  
positive.code: 
  -spec init([integer()]) -> {'ok', state()}.
  init([]) ->
      Interval = application:get_env(vmq_server, interval, 10),
      ets:new(?TABLE, [public, named_table, {write_concurrency, true}]),
      init_table(items()),
      IntervalMS = Interval * 1000,
      TRef = erlang:send_after(IntervalMS, self(), publish),
      erlang:send_after(1000, self(), shift),
      {ok, #state{interval=IntervalMS, ref=TRef}}.
  
  
negative.code: %%
  %% Licensed under the Apache License, Version 2.0 (the "License");
  %% you may not use this file except in compliance with the License.
  