@Test
	public void tap() throws Exception {
		StreamDefinitionRepository streamRepo = mock(StreamDefinitionRepository.class);
		parser = new XDStreamParser(streamRepo, moduleRegistry(),
				new DefaultModuleOptionsMetadataResolver());
		when(streamRepo.findOne("xxx")).thenReturn(new StreamDefinition("xxx", "http | file"));
		List<ModuleDescriptor> requests = parser.parse("test", "tap:stream:xxx.http > file", stream);
		assertEquals(1, requests.size());
		assertEquals("tap:stream:xxx.http.0", requests.get(0).getSourceChannelName());
		assertEquals(ModuleType.sink, requests.get(0).getType());
	}
@author Mark Fisher
@author David Turanski
spring-xd-dirt/src/test/java/org/springframework/xd/dirt/stream/XDStreamParserTests.java