From aeadb9c67a3c800d57afb9c1eb5281efb8f71fc4 Mon Sep 17 00:00:00 2001 From: sheheryar aamir Date: Mon, 1 Apr 2024 13:30:04 +0200 Subject: [PATCH] (fix): updated cloudstream googlepubsub example and added missing binding from auto-configuration --- .../SpringwolfGooglePubSubBindingAutoConfiguration.java | 8 ++++++++ .../src/test/resources/asyncapi.json | 7 ++++++- 2 files changed, 14 insertions(+), 1 deletion(-) diff --git a/springwolf-bindings/springwolf-googlepubsub-binding/src/main/java/io/github/springwolf/bindings/googlepubsub/configuration/SpringwolfGooglePubSubBindingAutoConfiguration.java b/springwolf-bindings/springwolf-googlepubsub-binding/src/main/java/io/github/springwolf/bindings/googlepubsub/configuration/SpringwolfGooglePubSubBindingAutoConfiguration.java index ebec0c490..bed282e86 100644 --- a/springwolf-bindings/springwolf-googlepubsub-binding/src/main/java/io/github/springwolf/bindings/googlepubsub/configuration/SpringwolfGooglePubSubBindingAutoConfiguration.java +++ b/springwolf-bindings/springwolf-googlepubsub-binding/src/main/java/io/github/springwolf/bindings/googlepubsub/configuration/SpringwolfGooglePubSubBindingAutoConfiguration.java @@ -2,6 +2,7 @@ package io.github.springwolf.bindings.googlepubsub.configuration; import io.github.springwolf.bindings.googlepubsub.scanners.channels.GooglePubSubChannelBindingProcessor; +import io.github.springwolf.bindings.googlepubsub.scanners.messages.GooglePubSubMessageBindingProcessor; import io.github.springwolf.core.asyncapi.scanners.bindings.BindingProcessorPriority; import io.github.springwolf.core.configuration.properties.SpringwolfConfigConstants; import org.springframework.boot.autoconfigure.AutoConfiguration; @@ -23,4 +24,11 @@ public class SpringwolfGooglePubSubBindingAutoConfiguration { public GooglePubSubChannelBindingProcessor googlePubSubChannelBindingProcessor() { return new GooglePubSubChannelBindingProcessor(); } + + @Bean + @Order(value = BindingProcessorPriority.PROTOCOL_BINDING) + @ConditionalOnMissingBean + public GooglePubSubMessageBindingProcessor googlePubSubMessageBindingProcessor() { + return new GooglePubSubMessageBindingProcessor(); + } } diff --git a/springwolf-examples/springwolf-cloud-stream-example/src/test/resources/asyncapi.json b/springwolf-examples/springwolf-cloud-stream-example/src/test/resources/asyncapi.json index dd0830f25..f4b27c4a3 100644 --- a/springwolf-examples/springwolf-cloud-stream-example/src/test/resources/asyncapi.json +++ b/springwolf-examples/springwolf-cloud-stream-example/src/test/resources/asyncapi.json @@ -220,7 +220,12 @@ "name": "io.github.springwolf.examples.cloudstream.dtos.GooglePubSubPayloadDto", "title": "GooglePubSubPayloadDto", "bindings": { - "kafka": { } + "googlepubsub": { + "schema": { + "name": "project/test" + }, + "bindingVersion": "0.2.0" + } } } }