Use 'unknown' when RabbitMQ version is missing

See gh-48484

Signed-off-by: Huang Xiao <[email protected]>

Author: youngledo

spring-boot-project/spring-boot-actuator/src/main/java/org/springframework/boot/actuate/amqp/RabbitHealthIndicator.java

@@ -45,8 +45,10 @@ protected void doHealthCheck(Health.Builder builder) throws Exception {
 	}
 
 	private String getVersion() {
-		return this.rabbitTemplate
-			.execute((channel) -> channel.getConnection().getServerProperties().get("version").toString());
+		return this.rabbitTemplate.execute((channel) -> channel.getConnection()
+			.getServerProperties()
+			.getOrDefault("version", "unknown")
+			.toString());
 	}
 
 }

spring-boot-project/spring-boot-actuator/src/test/java/org/springframework/boot/actuate/amqp/RabbitHealthIndicatorTests.java

@@ -75,6 +75,17 @@ void healthWhenConnectionFailsShouldReturnDown() {
 		assertThat(health.getStatus()).isEqualTo(Status.DOWN);
 	}
 
+	@Test
+	void healthWhenVersionIsMissingShouldReturnUpWithUnknownVersion() {
+		givenTemplateExecutionWillInvokeCallback();
+		Connection connection = mock(Connection.class);
+		given(this.channel.getConnection()).willReturn(connection);
+		given(connection.getServerProperties()).willReturn(Collections.emptyMap());
+		Health health = new RabbitHealthIndicator(this.rabbitTemplate).health();
+		assertThat(health.getStatus()).isEqualTo(Status.UP);
+		assertThat(health.getDetails()).containsEntry("version", "unknown");
+	}
+
 	private void givenTemplateExecutionWillInvokeCallback() {
 		given(this.rabbitTemplate.execute(any())).willAnswer((invocation) -> {
 			ChannelCallback<?> callback = invocation.getArgument(0);