@Test
	public void testMaskingOfPasswords() throws IOException {

		String streamName = generateStreamName();
		stream().createDontDeploy(streamName, "http | jdbc --password=mypassword");

		CommandResult cr = getShell().executeCommand("stream list");
		assertTrue("Failure.  CommandResult = " + cr.toString(), cr.isSuccess());
		Table table = (Table) cr.getResult();
		assertTrue(table.getRows().contains(
				new TableRow().addValue(1, streamName).addValue(2, "http | jdbc --password=**********").addValue(3,
						"undeployed")));
	}
Test a stream that is simply one processor module connecting two named channels.
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractStreamCommandsTests.java