31
31
import java .util .function .Function ;
32
32
33
33
import org .junit .jupiter .api .BeforeEach ;
34
- import org .junit .jupiter .api .Disabled ;
35
-
36
34
import org .springframework .dao .InvalidDataAccessApiUsageException ;
37
35
import org .springframework .data .redis .ObjectFactory ;
38
36
import org .springframework .data .redis .Person ;
@@ -465,7 +463,6 @@ void shouldApplyCustomSerializationContextToHash() {
465
463
466
464
@ ParameterizedRedisTest // DATAREDIS-612
467
465
@ EnabledIfLongRunningTest
468
- @ Disabled ("Caused often CancellationException: Disconnected" )
469
466
void listenToChannelShouldReceiveChannelMessagesCorrectly () throws InterruptedException {
470
467
471
468
String channel = "my-channel" ;
@@ -488,7 +485,6 @@ void listenToChannelShouldReceiveChannelMessagesCorrectly() throws InterruptedEx
488
485
489
486
@ ParameterizedRedisTest // GH-1622
490
487
@ EnabledIfLongRunningTest
491
- @ Disabled ("Caused often CancellationException: Disconnected" )
492
488
void listenToLaterChannelShouldReceiveChannelMessagesCorrectly () {
493
489
494
490
String channel = "my-channel" ;
@@ -511,7 +507,6 @@ void listenToLaterChannelShouldReceiveChannelMessagesCorrectly() {
511
507
}
512
508
513
509
@ ParameterizedRedisTest // DATAREDIS-612
514
- @ Disabled ("Caused often CancellationException: Disconnected" )
515
510
void listenToPatternShouldReceiveChannelMessagesCorrectly () {
516
511
517
512
String channel = "my-channel" ;
@@ -536,7 +531,6 @@ void listenToPatternShouldReceiveChannelMessagesCorrectly() {
536
531
}
537
532
538
533
@ ParameterizedRedisTest // GH-1622
539
- @ Disabled ("Caused often CancellationException: Disconnected" )
540
534
void listenToPatternLaterShouldReceiveChannelMessagesCorrectly () {
541
535
542
536
String channel = "my-channel" ;
0 commit comments