diff --git a/spring-pulsar-sample-apps/sample-pulsar-binder/src/main/java/org/springframework/pulsar/sample/binder/SpringPulsarBinderSampleApp.java b/spring-pulsar-sample-apps/sample-pulsar-binder/src/main/java/org/springframework/pulsar/sample/binder/SpringPulsarBinderSampleApp.java index 737bc207..4b1ee9e5 100644 --- a/spring-pulsar-sample-apps/sample-pulsar-binder/src/main/java/org/springframework/pulsar/sample/binder/SpringPulsarBinderSampleApp.java +++ b/spring-pulsar-sample-apps/sample-pulsar-binder/src/main/java/org/springframework/pulsar/sample/binder/SpringPulsarBinderSampleApp.java @@ -30,12 +30,14 @@ import org.springframework.context.annotation.Bean; import org.springframework.pulsar.annotation.PulsarListener; /** - * This sample binder app has an extra consumer that is equipped with Pulsar's DLT feature - timeLoggerToDlt. - * However, this consumer is not part of the spring.cloud.function.definition. - * In order to enable this, add the function timeLoggerToDlt to the definition in the application.yml file. - * When doing this, in order to minimize verbose output and just to focus on the DLT feature, comment out the + * This sample binder app has an extra consumer that is equipped with Pulsar's DLT feature + * - timeLoggerToDlt. However, this consumer is not part of the + * spring.cloud.function.definition. In order to enable this, add the function + * timeLoggerToDlt to the definition in the application.yml file. When doing this, in + * order to minimize verbose output and just to focus on the DLT feature, comment out the * regular supplier below (timeSupplier) and then un-comment the ApplicationRunner below. - * The runner only sends a single message whereas the supplier sends a message every second. + * The runner only sends a single message whereas the supplier sends a message every + * second. * * @author Soby Chacko */ @@ -53,17 +55,18 @@ public class SpringPulsarBinderSampleApp { return () -> new Time(String.valueOf(System.currentTimeMillis())); } -// @Bean -// ApplicationRunner runner(PulsarTemplate