From 176ac48a8ca6884b2a3b0faaa324f89c9031872c Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Mon, 7 Jun 2021 15:34:17 -0400 Subject: [PATCH] GH-171 Fix TimeSourceTests according SCST changes Related to: https://github.com/spring-cloud/stream-applications/issues/171 --- .../cloud/stream/app/source/time/TimeSourceTests.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/applications/source/time-source/src/test/java/org/springframework/cloud/stream/app/source/time/TimeSourceTests.java b/applications/source/time-source/src/test/java/org/springframework/cloud/stream/app/source/time/TimeSourceTests.java index 45525ecf..a1b86d5f 100644 --- a/applications/source/time-source/src/test/java/org/springframework/cloud/stream/app/source/time/TimeSourceTests.java +++ b/applications/source/time-source/src/test/java/org/springframework/cloud/stream/app/source/time/TimeSourceTests.java @@ -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 sourceMessage = target.receive(10000); + Message 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 sourceMessage = target.receive(10000, "output"); + Message sourceMessage = target.receive(10000, "foo"); TaskLaunchRequest taskLaunchRequest = objectMapper.readValue(sourceMessage.getPayload(), TaskLaunchRequest.class); assertThat(taskLaunchRequest.getTaskName()).isEqualTo("task-34");