From a28b73e93bb21fa6c8ec8a93ba9318817da0076f Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 23 Aug 2022 14:30:01 -0400 Subject: [PATCH] Fixing sample application --- .../src/main/java/app1/SpringPulsarBootApp.java | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) diff --git a/spring-pulsar-sample-apps/src/main/java/app1/SpringPulsarBootApp.java b/spring-pulsar-sample-apps/src/main/java/app1/SpringPulsarBootApp.java index 893846b1..e45f380c 100644 --- a/spring-pulsar-sample-apps/src/main/java/app1/SpringPulsarBootApp.java +++ b/spring-pulsar-sample-apps/src/main/java/app1/SpringPulsarBootApp.java @@ -19,6 +19,7 @@ package app1; import java.util.List; import java.util.UUID; +import org.apache.pulsar.client.api.Schema; import org.apache.pulsar.common.schema.SchemaType; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -28,6 +29,7 @@ import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.Bean; import org.springframework.pulsar.annotation.PulsarListener; +import org.springframework.pulsar.core.PulsarProducerFactory; import org.springframework.pulsar.core.PulsarTemplate; @SpringBootApplication @@ -86,9 +88,11 @@ public class SpringPulsarBootApp { * associated PulsarListener using an exclusive subscription. */ @Bean - ApplicationRunner runner3(PulsarTemplate pulsarTemplate) { + ApplicationRunner runner3(PulsarProducerFactory producerFactory) { String topic = "hello-pulsar-exclusive-3"; + PulsarTemplate pulsarTemplate = new PulsarTemplate<>(producerFactory); + pulsarTemplate.setSchema(Schema.JSON(Foo.class)); return args -> { for (int i = 0; i < 10; i++) { Foo foo = new Foo(i + "-" + "Foo-" + UUID.randomUUID(), i + "-" + "Bar-" + UUID.randomUUID()); @@ -107,9 +111,11 @@ public class SpringPulsarBootApp { * Publish and then use PulsarListener in batch listening mode. */ @Bean - ApplicationRunner runner4(PulsarTemplate pulsarTemplate) { + ApplicationRunner runner4(PulsarProducerFactory producerFactory) { String topic = "hello-pulsar-exclusive-4"; + PulsarTemplate pulsarTemplate = new PulsarTemplate<>(producerFactory); + pulsarTemplate.setSchema(Schema.JSON(Foo.class)); return args -> { for (int i = 0; i < 100; i++) { Foo foo = new Foo(i + "-" + "Foo-" + UUID.randomUUID(), i + "-" + "Bar-" + UUID.randomUUID());