anchor.diff:  %% 
   %% @end
   -spec vstream_subscribe_to_streams_interval(_) -> ok | {error, term()}.
  -vstream_subscribe_to_streams_interval(_) ->
  -	
  -	%% Create two streams in ?ES_INDEX
  -	StreamId1 = create_a_stream_on_index(?ES_INDEX),
  -	StreamId2 = create_a_stream_on_index(?ES_INDEX),
  +vstream_subscribe_to_streams_interval({VStreamId, StreamId1, StreamId2}) ->
   
   	%% Create virtual stream listening to our streams
  -	VPid = create_virtual_stream("testID",
  -								 [{stream, StreamId1}, {stream, StreamId2}],
  -								 count),
  +	%virtual_stream_process_supervisor:start_processes(),
  +	%timer:sleep(5000),
  +	virtual_stream_process_supervisor:add_child(VStreamId, [{stream, StreamId1}, {stream, StreamId2}], [list_to_binary("count"), "2s"]),
   	
   	%% Create publisher and consumer exchanges
   	OutExchange1 = list_to_binary("streams." ++ StreamId1),
   	OutExchange2 = list_to_binary("streams." ++ StreamId2),
  -	InExchange = list_to_binary("vstreams.testID"),
  +	InExchange = list_to_binary("vstreams." ++ VStreamId),
   	
   	%% Establish connection to RabbitMQ
   	{ok, Connection} =
  
positive.code: 		  end,
  	
  	%% Close and clean
  	VPid ! quit,
  	amqp_channel:close(ChannelIn),
  	amqp_channel:close(ChannelOut),
  	amqp_connection:close(Connection),
  	
  	case erlastic_search:delete_doc(?ES_INDEX,"stream", StreamId) of
  		{error, {Code, Body2}} ->
  			erlang:display(api_help:generate_error(Body2, Code));
  		{ok, _} -> ok
  	end,
  	
  	timer:sleep(1000),
  
  	[?_assertEqual(true, is_list(StreamId)),
  	 ?_assertEqual({32, "testID"}, Rec)].
  	
  
  
  
negative.code: 		  end,
  	
  	%% Close and clean
  	amqp_channel:close(ChannelIn),
  	amqp_channel:close(ChannelOut),
  	amqp_connection:close(Connection),
  
  	[?_assertEqual(true, is_list(StreamId1)),
  	 ?_assertEqual(true, is_list(StreamId2)),
  	 ?_assertEqual({32, VStreamId}, Rec1),
  	 ?_assertEqual({64, VStreamId}, Rec2)].
  
  
  
  