fix: restore createContributor for health indicators to maintain bean type compatibility

This change reverts the use of createComposite back to createContributor in PubSub and Spanner health auto-configurations. This ensures that when a single template is present, the registered bean is of type HealthIndicator, maintaining backward compatibility with existing tests and samples. Multi-template scenarios continue to be supported via CompositeHealthContributor.

Author: prathmeshcc

spring-cloud-gcp-autoconfigure/src/main/java/com/google/cloud/spring/autoconfigure/pubsub/health/PubSubHealthIndicatorAutoConfiguration.java

@@ -63,6 +63,6 @@ public PubSubHealthIndicatorAutoConfiguration(
   @ConditionalOnMissingBean(name = {"pubSubHealthIndicator", "pubSubHealthContributor"})
   public HealthContributor pubSubHealthContributor(Map<String, PubSubTemplate> pubSubTemplates) {
     Assert.notNull(pubSubTemplates, "pubSubTemplates must be provided");
-    return createComposite(pubSubTemplates);
+    return createContributor(pubSubTemplates);
   }
 }

spring-cloud-gcp-autoconfigure/src/main/java/com/google/cloud/spring/autoconfigure/spanner/health/SpannerHealthIndicatorAutoConfiguration.java

@@ -62,6 +62,6 @@ public SpannerHealthIndicatorAutoConfiguration(
   @ConditionalOnMissingBean(name = {"spannerHealthIndicator", "spannerHealthContributor"})
   public HealthContributor spannerHealthContributor(Map<String, SpannerTemplate> spannerTemplates) {
     Assert.notNull(spannerTemplates, "SpannerTemplates must be provided");
-    return createComposite(spannerTemplates);
+    return createContributor(spannerTemplates);
   }
 }

spring-cloud-gcp-autoconfigure/src/test/java/com/google/cloud/spring/autoconfigure/pubsub/health/PubSubHealthIndicatorAutoConfigurationTests.java

@@ -68,19 +68,12 @@ void healthIndicatorPresent_defaults() throws Exception {
         .withBean("pubSubTemplate", PubSubTemplate.class, () -> mockPubSubTemplate)
         .run(
             ctx -> {
-              HealthContributor healthContributor = ctx.getBean(HealthContributor.class);
-              assertThat(healthContributor).isNotNull();
-              PubSubHealthIndicator indicator;
-              if (healthContributor instanceof CompositeHealthContributor composite) {
-                indicator = (PubSubHealthIndicator) composite.getContributor("pubSubTemplate");
-              } else {
-                indicator = (PubSubHealthIndicator) healthContributor;
-              }
-              assertThat(indicator).isNotNull();
-              assertThat(indicator.getSubscription()).matches(UUID_PATTERN);
-              assertThat(indicator.getTimeoutMillis()).isEqualTo(5000);
-              assertThat(indicator.isAcknowledgeMessages()).isFalse();
-              assertThat(indicator.isSpecifiedSubscription()).isFalse();
+              PubSubHealthIndicator healthIndicator = ctx.getBean(PubSubHealthIndicator.class);
+              assertThat(healthIndicator).isNotNull();
+              assertThat(healthIndicator.getSubscription()).matches(UUID_PATTERN);
+              assertThat(healthIndicator.getTimeoutMillis()).isEqualTo(5000);
+              assertThat(healthIndicator.isAcknowledgeMessages()).isFalse();
+              assertThat(healthIndicator.isSpecifiedSubscription()).isFalse();
             });
   }
 
@@ -98,14 +91,7 @@ void healthIndicatorPresent_customConfig() {
             "spring.cloud.gcp.pubsub.health.acknowledgeMessages=true")
         .run(
             ctx -> {
-              HealthContributor healthContributor = ctx.getBean(HealthContributor.class);
-              assertThat(healthContributor).isNotNull();
-              PubSubHealthIndicator healthIndicator;
-              if (healthContributor instanceof CompositeHealthContributor composite) {
-                healthIndicator = (PubSubHealthIndicator) composite.getContributor("pubSubTemplate");
-              } else {
-                healthIndicator = (PubSubHealthIndicator) healthContributor;
-              }
+              PubSubHealthIndicator healthIndicator = ctx.getBean(PubSubHealthIndicator.class);
               assertThat(healthIndicator).isNotNull();
               assertThat(healthIndicator.getSubscription()).isEqualTo("test");
               assertThat(healthIndicator.getTimeoutMillis()).isEqualTo(1500);

spring-cloud-gcp-autoconfigure/src/test/java/com/google/cloud/spring/autoconfigure/spanner/health/SpannerHealthIndicatorAutoConfigurationTests.java

@@ -60,13 +60,7 @@ void testSpannerHealthIndicatorCreated() {
     final String defaultQuery = "SELECT 1";
     this.contextRunner.run(
         context -> {
-          HealthContributor contributor = context.getBean(HealthContributor.class);
-          SpannerHealthIndicator indicator;
-          if (contributor instanceof CompositeHealthContributor composite) {
-            indicator = (SpannerHealthIndicator) composite.getContributor("spannerTemplate");
-          } else {
-            indicator = (SpannerHealthIndicator) contributor;
-          }
+          SpannerHealthIndicator indicator = context.getBean(SpannerHealthIndicator.class);
           assertThat(indicator).isNotNull();
           assertThat(indicator)
               .hasFieldOrPropertyWithValue("validationStatement", Statement.of(defaultQuery));
@@ -80,13 +74,7 @@ void testSpannerHealthIndicatorCreatedWithQuery() {
         .withPropertyValues("spring.cloud.gcp.spanner.health.query=" + customQuery)
         .run(
             context -> {
-              HealthContributor contributor = context.getBean(HealthContributor.class);
-              SpannerHealthIndicator indicator;
-              if (contributor instanceof CompositeHealthContributor composite) {
-                indicator = (SpannerHealthIndicator) composite.getContributor("spannerTemplate");
-              } else {
-                indicator = (SpannerHealthIndicator) contributor;
-              }
+              SpannerHealthIndicator indicator = context.getBean(SpannerHealthIndicator.class);
               assertThat(indicator).isNotNull();
               assertThat(indicator)
                   .hasFieldOrPropertyWithValue("validationStatement", Statement.of(customQuery));