From 09a47b06a133d1a645d0d06814c762e506d95bbb Mon Sep 17 00:00:00 2001 From: manyasi06 <10466887+manyasi06@users.noreply.github.com> Date: Wed, 14 Jun 2023 17:20:27 -0400 Subject: [PATCH] add test for improving coverage defaultbinder --- .../stream/binder/DefaultBinderTests.java | 30 +++++++++++++++++++ 1 file changed, 30 insertions(+) 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(); + } }