@ -55,7 +55,7 @@ class RedisReactiveHealthIndicatorTests {
@@ -55,7 +55,7 @@ class RedisReactiveHealthIndicatorTests {
ReactiveRedisConnection redisConnection = mock ( ReactiveRedisConnection . class ) ;
given ( redisConnection . closeLater ( ) ) . willReturn ( Mono . empty ( ) ) ;
ReactiveServerCommands commands = mock ( ReactiveServerCommands . class ) ;
given ( commands . info ( ) ) . willReturn ( Mono . just ( info ) ) ;
given ( commands . info ( "server" ) ) . willReturn ( Mono . just ( info ) ) ;
RedisReactiveHealthIndicator healthIndicator = createHealthIndicator ( redisConnection , commands ) ;
Mono < Health > health = healthIndicator . health ( ) ;
StepVerifier . create ( health ) . consumeNextWith ( ( h ) - > {
@ -73,7 +73,7 @@ class RedisReactiveHealthIndicatorTests {
@@ -73,7 +73,7 @@ class RedisReactiveHealthIndicatorTests {
ReactiveRedisConnection redisConnection = mock ( ReactiveRedisClusterConnection . class ) ;
given ( redisConnection . closeLater ( ) ) . willReturn ( Mono . empty ( ) ) ;
ReactiveClusterServerCommands commands = mock ( ReactiveClusterServerCommands . class ) ;
given ( commands . info ( ) ) . willReturn ( Mono . just ( info ) ) ;
given ( commands . info ( "server" ) ) . willReturn ( Mono . just ( info ) ) ;
RedisReactiveHealthIndicator healthIndicator = createHealthIndicator ( redisConnection , commands ) ;
Mono < Health > health = healthIndicator . health ( ) ;
StepVerifier . create ( health ) . consumeNextWith ( ( h ) - > {
@ -87,7 +87,7 @@ class RedisReactiveHealthIndicatorTests {
@@ -87,7 +87,7 @@ class RedisReactiveHealthIndicatorTests {
@Test
void redisCommandIsDown ( ) {
ReactiveServerCommands commands = mock ( ReactiveServerCommands . class ) ;
given ( commands . info ( ) ) . willReturn ( Mono . error ( new RedisConnectionFailureException ( "Connection failed" ) ) ) ;
given ( commands . info ( "server" ) ) . willReturn ( Mono . error ( new RedisConnectionFailureException ( "Connection failed" ) ) ) ;
ReactiveRedisConnection redisConnection = mock ( ReactiveRedisConnection . class ) ;
given ( redisConnection . closeLater ( ) ) . willReturn ( Mono . empty ( ) ) ;
RedisReactiveHealthIndicator healthIndicator = createHealthIndicator ( redisConnection , commands ) ;