anchor.diff:                                  %% Send messages to live update
   								send_messages(TriggerExchange,ChannelOut,Messages),
                                   %% Send to standard output
  +                                %% TODO: Parallelize, spawn one process for each Message?
                                   send_to_output(TriggerId, Messages),
   								
   								loop(TriggerId, NewDataPoints, TriggerExchange,Net, Function, OutputList);
  
positive.code:             ok;
          {ok, {{_, Code, _}, _, Body}} ->
              {error, {Code, Body}}
      end.
  send_to_output(TriggerId, {Value, Timestamp, StreamId, Input, [_|Rest]}) ->
      case httpc:request(post, {URI, [],"application/json", Message}, [], []) of
          {ok,{{_, 200, _}, _, _}} ->
              ok;
          {ok, {{_, Code, _}, _, Body}} ->
              {error, {Code, Body}}
      end.
                
  
  handle_command({add,{Input,User}},[]) ->
  
negative.code: 
  
  
  %% ====================================================================
  %% Helper functions
  %% ====================================================================
  