anchor.diff:              #st{subscribers = Subs} = St) ->
       case lists:keyfind(Key, #subscriber.key, Subs) of
           #subscriber{} = Sub ->
  -            case {RetryFailedMetrics,  exometer:get_value(Metric, DataPoint)} of
  -                %% We found a value.
  -                {_, {ok, Values}} ->
  +            case {RetryFailedMetrics,  get_values(Metric, DataPoint)} of
  +                %% We found a value, or values.
  +                {_, [_|_] = Found} ->
                       %% Distribute metric value to the correct process
  -                    [report_value(Reporter, Metric, DP, Extra, Val)
  -                     || {DP, Val} <- Values],
  +                    [[report_value(Reporter, Name, DP, Extra, Val)
  +		      || {DP, Val} <- Values] || {Name, Values} <- Found],
   
                       %% Re-arm the timer for next round
                       TRef = erlang:send_after(Interval, self(),
  
positive.code: restart_rec(L) ->
      Save = lists:foldl(
               fun
                   ({R,_}, Acc) when is_integer(R) -> 
                       erlang:max(R, Acc);
                   (_, Acc) -> 
                       Acc
               end, 0, L),
      #restart{spec = L, save_n = Save}.
  
negative.code: subscribe(Reporter, Metric, DataPoint, Interval) ->
      subscribe(Reporter, Metric, DataPoint, Interval, []).
  
  -spec subscribe(module(), metric(), datapoint(), interval(), extra()) ->
      ok | not_found | unknown_reporter.
  %% @doc Add a subscription to an existing reporter.
  %%
  