From fdf6d7a09a423e76a25ec9833102ec4693859154 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 17 Oct 2022 17:20:03 +0200 Subject: [PATCH] GH-2429 Add default implementation of isPaused() to Binding Resolves #2429 --- .../org/springframework/cloud/stream/binder/Binding.java | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/Binding.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/Binding.java index 275a26460..bef38c71f 100644 --- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/Binding.java +++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/binder/Binding.java @@ -62,6 +62,14 @@ public interface Binding extends Pausable { default void stop() { } + /** + * Will always return false unless overriden. + */ + @Override + default boolean isPaused() { + return false; + } + /** * Pauses the target component represented by this instance if and only if the * component implements {@link Pausable} interface NOTE: At the time the instance is