From 7e3681dafe92f5c4918d9619976b8e36cc0d9de5 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Wed, 16 Oct 2019 14:07:09 +0200 Subject: [PATCH] Rename Pollable to PollableBean --- .../{Pollable.java => PollableBean.java} | 25 +++++++++---------- 1 file changed, 12 insertions(+), 13 deletions(-) rename spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/{Pollable.java => PollableBean.java} (63%) diff --git a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/Pollable.java b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/PollableBean.java similarity index 63% rename from spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/Pollable.java rename to spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/PollableBean.java index 915826a6d..133bc2e18 100644 --- a/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/Pollable.java +++ b/spring-cloud-function-context/src/main/java/org/springframework/cloud/function/context/PollableBean.java @@ -27,19 +27,18 @@ import org.springframework.context.annotation.Bean; /** * - * A marker annotation to signal to the consumers of the - * annotated {@link Supplier} method that regardless of its type signature - * (reactive or imperative), such supplier needs to be polled - * periodically. This has special significance to the reactive suppliers (e.g., {@code Supplier}), - * since in most cases they are treated as producers of an infinite stream - * that is managed independently once produced. However if such suppliers produce a stream hat is finite - * they may need to be called again. - * + * A marker and qualifier annotation to signal that + * annotated functional factory method is a bean (e.g., Supplier, Function or Consumer) + * that also needs to be polled periodically. *
- * NOTE: Given that polling behavior is specific to the users (consumers) of the annotated supplier, - * spring-cloud-function provides no default post processing behavior which means that annotating a - * factory method with this annotation will not have any effect without some application/framework - * specific post processing. + * This has special significance to the reactive suppliers (e.g., {@code Supplier>}), + * since by default they are treated as producers of an infinite stream. + * However if such suppliers produce a finite stream they may need to be triggered again. + *
+ *
+ * NOTE: The spring-cloud-function framework provides no default post processing behavior for this annotation. This + * means that annotating a factory method with this annotation will not have any effect without some application/framework + * specific post processing (see spring-cloud-stream as an example). * * * @author Oleg Zhurakousky @@ -50,7 +49,7 @@ import org.springframework.context.annotation.Bean; @Retention(RetentionPolicy.RUNTIME) @Bean @Documented -public @interface Pollable { +public @interface PollableBean { /** * Signals to the post processors of this annotation that the result produced by the