Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Formatting the binder sample app

Browse Source
This commit is contained in:
Soby Chacko
2023-03-21 19:18:16 -04:00
parent 2609b08869
commit 0f84199138
1 changed files with 19 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

35
spring-pulsar-sample-apps/sample-pulsar-binder/src/main/java/org/springframework/pulsar/sample/binder/SpringPulsarBinderSampleApp.java
View File

@@ -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<Time> pulsarTemplate) {
//
// String topic = "timeSupplier-out-0";
//
// return args -> {
// for (int i = 0; i < 1; i++) {
// pulsarTemplate.send(topic, new Time(String.valueOf(System.currentTimeMillis())), Schema.JSON(Time.class));
// }
// };
// }
// @Bean
// ApplicationRunner runner(PulsarTemplate<Time> pulsarTemplate) {
//
// String topic = "timeSupplier-out-0";
//
// return args -> {
// for (int i = 0; i < 1; i++) {
// pulsarTemplate.send(topic, new Time(String.valueOf(System.currentTimeMillis())),
// Schema.JSON(Time.class));
// }
// };
// }
@Bean
public Function<Time, EnhancedTime> timeProcessor() {