anchor.diff:  	Timeout :: non_neg_integer() | infinity.
   %% ====================================================================
   handle_info({#'basic.deliver'{}, #amqp_msg{payload = Body}},
  -			State = #state{vstreamid = VStreamId, datapoints = DataPoints,
  -						   exchange = VStreamExchange, network = Net,
  -						   function = Function}) ->
  +			State = #vsstate{vstreamid = VStreamId, datapoints = DataPoints,
  +						     exchange = VStreamExchange, network = Net,
  +						     function = Function}) ->
   	Data = binary_to_list(Body),
   	case erlson:is_json_string(Data) of
   		%% New value from the source as a Json
  
positive.code: 
  
  
  %% spec of record state:
  %% {string(), [{atom(),string()}], binary(), {pid(), pid(), pid()}, atom()}
  -record(state, {vstreamid, datapoints, exchange, network, function, log, history_size, last_updated}).
  
  
  
  
negative.code: 									Time -> binary_to_list(Time)
  								end,
  							%% Create state
  							State = #vsstate{vstreamid=VStreamId,
  										     datapoints = DataPoints,
  										     exchange = VStreamExchange,
  										     network = {Connection, ChannelIn, ChannelOut},
  										     function = Function,
  										     log = [],
  										     history_size = HistorySize,
  										     last_updated = LastUpdated},
  						    {ok, State}
  					end
  			end
  