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

GH-171 Fix TimeSourceTests according SCST changes

Browse Source 
Related to: https://github.com/spring-cloud/stream-applications/issues/171
This commit is contained in:
Artem Bilan
2021-06-07 15:34:17 -04:00
parent d1aa6201c5
commit 176ac48a8c
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
applications/source/time-source/src/test/java/org/springframework/cloud/stream/app/source/time/TimeSourceTests.java
View File

@@ -42,6 +42,7 @@ import static org.assertj.core.api.Assertions.assertThatCode;
/**
* @author Soby Chacko
* @author David Turanski
* @author Artem Bilan
*/
public class TimeSourceTests {
@@ -54,7 +55,7 @@ public class TimeSourceTests {
.run("--spring.cloud.function.definition=timeSupplier")) {
OutputDestination target = context.getBean(OutputDestination.class);
Message<byte[]> sourceMessage = target.receive(10000);
Message<byte[]> sourceMessage = target.receive(10000, "timeSupplier-out-0");
final String actual = new String(sourceMessage.getPayload());
TimeSupplierProperties timeSupplierProperties = context.getBean(TimeSupplierProperties.class);
@@ -94,7 +95,7 @@ public class TimeSourceTests {
"--task.launch.request.task-name-expression='task-'+headers['task-id']")) {
OutputDestination target = context.getBean(OutputDestination.class);
Message<byte[]> sourceMessage = target.receive(10000, "output");
Message<byte[]> sourceMessage = target.receive(10000, "foo");
TaskLaunchRequest taskLaunchRequest = objectMapper.readValue(sourceMessage.getPayload(),
TaskLaunchRequest.class);
assertThat(taskLaunchRequest.getTaskName()).isEqualTo("task-34");