anchor.diff:  %% 
   %% @end
   -spec vstream_subscribe_to_a_stream(_) -> ok | {error, term()}.
  -vstream_subscribe_to_a_stream(_) ->
  -
  -	%% Create a stream in ?ES_INDEX
  -	StreamId = create_a_stream_on_index(?ES_INDEX),
  +vstream_subscribe_to_a_stream({VStreamId, StreamId1, _StreamId2}) ->
   	
   	%% Create virtual stream listening to our stream
  -	VPid = create_virtual_stream("testID", [{stream, StreamId}], count),
  +	%virtual_stream_process_supervisor:start_processes(),
  +	%timer:sleep(5000),
  +	virtual_stream_process_supervisor:add_child(VStreamId, [{stream, StreamId1}], [list_to_binary("count"), "2s"]),
   	
   	%% Create a publisher and consumer exchanges
  -	OutExchange = list_to_binary("streams." ++ StreamId),
  -	InExchange = list_to_binary("vstreams.testID"),
  +	OutExchange = list_to_binary("streams." ++ StreamId1),
  +	InExchange = list_to_binary("vstreams." ++ VStreamId),
   	
   	%% Establish connection to RabbitMQ
   	{ok, Connection} =
  
positive.code: 	float_to_list(Value).
  
  
  
negative.code: 	timer:sleep(1000),
  	
  	%% Publish a message
  	Msg = create_data_point(StreamId1, 32),
  	amqp_channel:cast(ChannelOut,
  					  #'basic.publish'{exchange = OutExchange},
  					  #amqp_msg{payload = Msg}),	
  