File tree Expand file tree Collapse file tree 2 files changed +5
-1
lines changed
src/test/java/com/rabbitmq/client/amqp/impl Expand file tree Collapse file tree 2 files changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -21,6 +21,10 @@ docker exec rabbitmq0 rabbitmqctl enable_feature_flag --opt-in khepri_db
2121docker exec rabbitmq1 rabbitmqctl enable_feature_flag --opt-in khepri_db
2222docker exec rabbitmq2 rabbitmqctl enable_feature_flag --opt-in khepri_db
2323
24+ docker exec rabbitmq0 rabbitmqctl set_log_level debug
25+ docker exec rabbitmq1 rabbitmqctl set_log_level debug
26+ docker exec rabbitmq2 rabbitmqctl set_log_level debug
27+
2428docker exec rabbitmq0 rabbitmqctl cluster_status
2529
2630docker compose --file ci/cluster/docker-compose.yml ps
Original file line number Diff line number Diff line change @@ -352,7 +352,7 @@ void consumeFromQuorumQueueWhenLeaderIsPaused() throws InterruptedException {
352352 consumeSync .reset ();
353353
354354 waitAtMost (
355- ofSeconds (60 ),
355+ ofSeconds (20 ),
356356 () -> initialFollowers .contains (mgmt .queueInfo (q ).leader ()),
357357 () ->
358358 "Current leader is not in initial followers, initial followers "
You can’t perform that action at this time.
0 commit comments