SpringCloud/stream-applications
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Increase timeouts on SftpSupplierApplicationTests

Browse Source
This commit is contained in:
David Turanski
2020-11-10 14:11:57 -05:00
parent 4102ff2f4f
commit 426e058ad1
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
functions/supplier/sftp-supplier/src/test/java/org/springframework/cloud/fn/supplier/sftp/SftpSupplierApplicationTests.java
View File

@@ -92,7 +92,7 @@ public class SftpSupplierApplicationTests extends SftpTestSupport {
.isEqualTo(MediaType.TEXT_PLAIN);
})
.expectTimeout(Duration.ofMillis(1000))
.verify(Duration.ofSeconds(10));
.verify(Duration.ofSeconds(30));
});
}
@@ -113,7 +113,7 @@ public class SftpSupplierApplicationTests extends SftpTestSupport {
assertThat(expectedFileName.get()).contains(message.getPayload());
})
.expectTimeout(Duration.ofMillis(1000))
.verify(Duration.ofSeconds(10));
.verify(Duration.ofSeconds(30));
});
}
@@ -142,7 +142,7 @@ public class SftpSupplierApplicationTests extends SftpTestSupport {
.expectNextMatches(
message -> expectedFileNames.get().contains(message.getPayload().getAbsolutePath()))
.thenCancel()
.verify(Duration.ofSeconds(10));
.verify(Duration.ofSeconds(30));
assertThat(metadataStore.get("sftpSource/sftpSource1.txt")).isNotNull();
assertThat(metadataStore.get("sftpSource/sftpSource2.txt")).isNotNull();
@@ -166,8 +166,8 @@ public class SftpSupplierApplicationTests extends SftpTestSupport {
.expectNextMatches(message -> message.getPayload().length > 0)
.expectNextMatches(message -> message.getPayload().length > 0)
.thenCancel()
.verify(Duration.ofSeconds(10));
await().atMost(Duration.ofSeconds(10))
.verify(Duration.ofSeconds(30));
await().atMost(Duration.ofSeconds(30))
.until(() -> getSourceRemoteDirectory().list().length == 0);
});
@@ -210,7 +210,7 @@ public class SftpSupplierApplicationTests extends SftpTestSupport {
}
})
.thenCancel()
.verify(Duration.ofSeconds(10));
.verify(Duration.ofSeconds(30));
});
}
@@ -257,7 +257,7 @@ public class SftpSupplierApplicationTests extends SftpTestSupport {
.expectNextMatches(message -> expectedContentsOfAllFiles.get()
.contains(new String(message.getPayload())))
.thenCancel()
.verify(Duration.ofSeconds(10));
.verify(Duration.ofSeconds(30));
});
}
finally {