@Test
	public void testDefaultOptions() {
		HttpSource httpSource = newHttpSource();
		FileSink fileSink = newFileSink().binary(true);

		String streamName = generateStreamName();
		Queue queue = new Queue(streamName);
		rabbitAdmin.declareQueue(queue);
		queues.add(streamName);


		stream().create(streamName, "%s | rabbit", httpSource);
		stream().create(generateStreamName(), "rabbit --queues=%s | %s", streamName, fileSink);

		httpSource.ensureReady().postData("hello rabbit");
		assertThat(fileSink, eventually(hasContentsThat(equalTo("hello rabbit"))));
	}
Tests for the rabbit source and sink modules.

@author Eric Bottard
@author Ilayaperumal Gopinathan
spring-xd-shell/src/test/java/org/springframework/xd/shell/command/AbstractRabbitSourceAndRabbitSinkTests.java