anchor.diff:  %% @end
   receive_loop([]) ->
   	ok;
  -receive_loop([{Value,StreamId,Threshold,Users}|Rest]) ->
  +receive_loop([{Value,StreamId,Threshold,Users,Type}|Rest]) ->
   	receive
   		{#'basic.deliver'{}, #amqp_msg{payload = Body}} ->
  -			{Value1,_,StreamId1,Threshold1,Users1} = binary_to_term(Body),
  -			case {Value1,StreamId1,Threshold1,Users1} == {Value,StreamId,Threshold,Users} of
  +			{Value1,_,StreamId1,Threshold1,Users1,Type1} = binary_to_term(Body),
  +			case {Value1,StreamId1,Threshold1,Users1,Type1} == {Value,StreamId,Threshold,Users,Type} of
   				true ->
   					receive_loop(Rest);
   				false ->
   					self() ! {#'basic.deliver'{}, #amqp_msg{payload = Body}},
  -					receive_loop([{Value,StreamId,Threshold,Users}|Rest])
  +					receive_loop([{Value,StreamId,Threshold,Users,Type}|Rest])
   			end
   	end.
   %% @doc
  
positive.code: 		{ok,{{_,200,_},_,_}} = httpc:request(post,{?WEBMACHINE_URL++"/users/"++UserId1++"/triggers/add",[],
  							       "application/json",
  							       "{\"function\" : \"less_than\",\"input\":5,\"streams\":[\"" 
  							       ++ StreamId1 ++ "\",\""++StreamId2 ++"\"]}"}, [], []),
  		{ok,{{_,200,_},_,_}} = httpc:request(post,{?WEBMACHINE_URL++"/users/"++UserId1++"/triggers/add",[],
  							       "application/json",
  							       "{\"function\" : \"less_than\",\"input\":4,\"streams\":\"" 
  							       ++ StreamId2 ++"\"}"}, [], []),
  		api_help:refresh(),
  		{UserId1, StreamId1, StreamId2}
  	end,
  
negative.code: 		{ok,{{_,200,_},_,_}} = httpc:request(post,{?WEBMACHINE_URL++"/users/"++UserId1++"/triggers/remove",[],
  							   "application/json",
  							   "{\"function\" : \"less_than\",\"input\":5,\"streams\":[\"" 
  							   ++ StreamId1 ++ "\",\""++StreamId2 ++"\"], \"vstreams\":\"\"}"}, [], []),
  		{ok,{{_,200,_},_,_}} = httpc:request(post,{?WEBMACHINE_URL++"/users/"++UserId1++"/triggers/remove",[],
  							       "application/json",
  							       "{\"function\" : \"less_than\",\"input\":4,\"streams\":\"" 
  							       ++StreamId2 ++"\", \"vstreams\":\"\"}"}, [], []),
  		{ok,{{_,200,_},_,_}} = httpc:request(delete,{?WEBMACHINE_URL++"/streams/"++StreamId1,[]},[],[]),
  		{ok,{{_,200,_},_,_}} = httpc:request(delete,{?WEBMACHINE_URL++"/streams/"++StreamId2,[]},[],[]),
  		{ok,{{_,200,_},_,_}} = httpc:request(delete,{?WEBMACHINE_URL++"/users/"++UserId1,[]},[],[])
  