diff --git a/applications/sink/counter-sink/src/test/java/org/springframework/cloud/stream/app/sink/counter/CounterSinkTests.java b/applications/sink/counter-sink/src/test/java/org/springframework/cloud/stream/app/sink/counter/CounterSinkTests.java
index 35696cfd..ab8973b2 100644
--- a/applications/sink/counter-sink/src/test/java/org/springframework/cloud/stream/app/sink/counter/CounterSinkTests.java
+++ b/applications/sink/counter-sink/src/test/java/org/springframework/cloud/stream/app/sink/counter/CounterSinkTests.java
@@ -20,7 +20,6 @@ import java.nio.charset.StandardCharsets;
import io.micrometer.core.instrument.Counter;
import io.micrometer.core.instrument.simple.SimpleMeterRegistry;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.springframework.boot.WebApplicationType;
@@ -41,7 +40,6 @@ import static org.assertj.core.api.Assertions.assertThat;
public class CounterSinkTests {
@Test
- @Disabled
public void testCounterSink() {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(CounterSinkTestApplication.class))
diff --git a/applications/sink/log-sink/src/test/java/org/springframework/cloud/stream/app/sink/log/LogSinkTests.java b/applications/sink/log-sink/src/test/java/org/springframework/cloud/stream/app/sink/log/LogSinkTests.java
index 6a4e77d5..c50b98fc 100644
--- a/applications/sink/log-sink/src/test/java/org/springframework/cloud/stream/app/sink/log/LogSinkTests.java
+++ b/applications/sink/log-sink/src/test/java/org/springframework/cloud/stream/app/sink/log/LogSinkTests.java
@@ -19,7 +19,6 @@ package org.springframework.cloud.stream.app.sink.log;
import java.nio.charset.StandardCharsets;
import org.awaitility.Awaitility;
-import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
@@ -42,7 +41,6 @@ import org.springframework.messaging.support.GenericMessage;
public class LogSinkTests {
@Test
- @Disabled
public void testSourceFromSupplier(CapturedOutput output) {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(LogSinkTestApplication.class))
diff --git a/applications/stream-applications-core/pom.xml b/applications/stream-applications-core/pom.xml
index fbe7390c..c3cd2b9a 100644
--- a/applications/stream-applications-core/pom.xml
+++ b/applications/stream-applications-core/pom.xml
@@ -23,9 +23,9 @@
2.0.0.M2
3.0.0.M1
3.0.2.RELEASE
- 3.0.2.RELEASE
- Hoxton.SR5
- Horsham.SR5
+ 3.0.7.RELEASE
+ Hoxton.BUILD-SNAPSHOT
+ Horsham.BUILD-SNAPSHOT
2.1.2.RELEASE
1.0.0-SNAPSHOT
0.9.0
diff --git a/functions/function/http-request-function/src/test/java/org/springframework/cloud/fn/http/request/HttpRequestFunctionApplicationTests.java b/functions/function/http-request-function/src/test/java/org/springframework/cloud/fn/http/request/HttpRequestFunctionApplicationTests.java
index 8f13e6fa..4dae06db 100644
--- a/functions/function/http-request-function/src/test/java/org/springframework/cloud/fn/http/request/HttpRequestFunctionApplicationTests.java
+++ b/functions/function/http-request-function/src/test/java/org/springframework/cloud/fn/http/request/HttpRequestFunctionApplicationTests.java
@@ -183,7 +183,7 @@ public class HttpRequestFunctionApplicationTests {
runner.run(context -> {
HttpRequestFunction httpRequestFunction = context.getBean(HttpRequestFunction.class);
StepVerifier.create(httpRequestFunction.apply(Flux.just(new GenericMessage(""))))
- .expectErrorMatches(throwable -> throwable.getMessage().startsWith("Connection refused"))
+ .expectErrorMatches(throwable -> throwable.getMessage().contains("Connection refused"))
.verify();
});
}