Fixing FTP Source tests

2021-06-08 15:15:17 -04:00
parent 32c9b38542
commit 4bdd1709b4
1 changed files with 1 additions and 1 deletions
--- 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");