anchor.diff:          Exchange = list_to_binary(atom_to_list(Type) ++ "s." ++ Id),
           create_input_exchanges(InputIds, [Exchange | Exchanges]).
           
  -
  -
  -
  -
   
   
   
  
positive.code:             {error, {Code, Body}};
          {ok, Response} ->
              ok
      end;
  send_to_output(TriggerId, {Value, Timestamp, StreamId, Input, [{uri,URI}|Rest]}) ->
      Message = lib_json:set_attrs([
          {trigger, "{}"},
          {"trigger.value", Value},
          {"trigger.timestamp", Timestamp},
          {"trigger.stream_id", StreamId},
  
negative.code: 
  
  
  %% @doc
  %% Function: get_first_value_for_streams()/1
  %% Purpose: Used to get the latest value for each stream/virtual stream
  