diff --git a/applications/source/ftp-source/src/test/java/org/springframework/cloud/stream/app/source/ftp/FtpSourceTests.java b/applications/source/ftp-source/src/test/java/org/springframework/cloud/stream/app/source/ftp/FtpSourceTests.java
index 0de38641..46430cd4 100644
--- a/applications/source/ftp-source/src/test/java/org/springframework/cloud/stream/app/source/ftp/FtpSourceTests.java
+++ b/applications/source/ftp-source/src/test/java/org/springframework/cloud/stream/app/source/ftp/FtpSourceTests.java
@@ -55,7 +55,7 @@ public class FtpSourceTests extends FtpTestSupport {
 
 	@Test
 	public void testFtpource() {
-		Message<byte[]> message = output.receive(10000);
+		Message<byte[]> message = output.receive(10000, "ftpSupplier-out-0");
 		assertThat(new File(new String(message.getPayload()).replaceAll("\"", ""))).isEqualTo(
 				new File(this.config.getLocalDir(), "ftpSource1.txt"));
 		message = output.receive(10000, "ftpSupplier-out-0");