diff --git a/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/DefaultBinderTests.java b/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/DefaultBinderTests.java index 16c1e4171..223255c0a 100644 --- a/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/DefaultBinderTests.java +++ b/core/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/binder/DefaultBinderTests.java @@ -17,6 +17,7 @@ package org.springframework.cloud.stream.binder; import org.junit.jupiter.api.Test; +import org.springframework.context.Lifecycle; import static org.assertj.core.api.Assertions.assertThat; @@ -39,4 +40,33 @@ public class DefaultBinderTests { assertThat(binding.isPaused()).isTrue(); } + + @Test + void testDefaultBinderIsNull(){ + DefaultBinding binding = new DefaultBinding<>("foo", "bar", "target", null); + assertThat(binding.getState()).isNotNull(); + } + + @Test + void testDefaultBinderIsRunning(){ + DefaultBinding binding = new DefaultBinding<>("foo", "bar", "target", new Lifecycle() { + private Boolean running =false; + @Override + public void start() { + running = !this.running; + } + + @Override + public void stop() { + running = !this.running; + } + + @Override + public boolean isRunning() { + return running; + } + }); + binding.start(); + assertThat(binding.isRunning()).isTrue(); + } }