Fix test and format

Author: onobc

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/pulsar/PulsarProperties.java

@@ -975,7 +975,7 @@ public enum FailurePolicy {
 		CONTINUE,
 
 		/** Retry startup asynchronously. */
-		RETRY;
+		RETRY
 
 	}
 

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/pulsar/PulsarReactivePropertiesMapper.java

@@ -25,7 +25,6 @@
 import org.springframework.boot.autoconfigure.pulsar.PulsarProperties.FailurePolicy;
 import org.springframework.boot.context.properties.PropertyMapper;
 import org.springframework.pulsar.config.StartupFailurePolicy;
-import org.springframework.pulsar.listener.PulsarContainerProperties;
 import org.springframework.pulsar.reactive.listener.ReactivePulsarContainerProperties;
 
 /**

spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/pulsar/PulsarPropertiesTests.java

@@ -403,7 +403,7 @@ void bind() {
 			assertThat(properties.getConcurrency()).isEqualTo(10);
 			assertThat(properties.isObservationEnabled()).isTrue();
 			assertThat(properties.getStartup().getOnFailure()).isEqualTo(FailurePolicy.RETRY);
-			assertThat(properties.getStartup().getTimeout()).isEqualTo(Duration.ofSeconds(13));
+			assertThat(properties.getStartup().getTimeout()).isEqualTo(Duration.ofMinutes(2));
 		}
 
 	}
@@ -420,15 +420,15 @@ void bind() {
 			map.put("spring.pulsar.reader.subscription-role-prefix", "sub-role");
 			map.put("spring.pulsar.reader.read-compacted", "true");
 			map.put("spring.pulsar.reader.startup.on-failure", "continue");
-			map.put("spring.pulsar.reader.startup.timeout", "2m");
+			map.put("spring.pulsar.reader.startup.timeout", "23s");
 			PulsarProperties.Reader properties = bindProperties(map).getReader();
 			assertThat(properties.getName()).isEqualTo("my-reader");
 			assertThat(properties.getTopics()).containsExactly("my-topic");
 			assertThat(properties.getSubscriptionName()).isEqualTo("my-subscription");
 			assertThat(properties.getSubscriptionRolePrefix()).isEqualTo("sub-role");
 			assertThat(properties.isReadCompacted()).isTrue();
 			assertThat(properties.getStartup().getOnFailure()).isEqualTo(FailurePolicy.CONTINUE);
-			assertThat(properties.getStartup().getTimeout()).isEqualTo(Duration.ofMinutes(2));
+			assertThat(properties.getStartup().getTimeout()).isEqualTo(Duration.ofSeconds(23));
 		}
 
 	}