Skip to content

Commit 5899af9

Browse files
committed
Remove classic mirror queues
1 parent 9b6cb03 commit 5899af9

File tree

100 files changed

+300
-11285
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

100 files changed

+300
-11285
lines changed

deps/rabbit/BUILD.bazel

Lines changed: 3 additions & 80 deletions
Original file line numberDiff line numberDiff line change
@@ -87,9 +87,6 @@ _APP_ENV = """[
8787
{ssl_apps, [asn1, crypto, public_key, ssl]},
8888
%% classic queue storage implementation version
8989
{classic_queue_default_version, 2},
90-
%% see rabbitmq-server#114
91-
{mirroring_flow_control, true},
92-
{mirroring_sync_batch_size, 4096},
9390
%% see rabbitmq-server#227 and related tickets.
9491
%% msg_store_credit_disc_bound only takes effect when
9592
%% messages are persisted to the message store. If messages
@@ -395,7 +392,7 @@ rabbitmq_integration_suite(
395392
additional_beam = [
396393
":test_queue_utils_beam",
397394
],
398-
shard_count = 7,
395+
shard_count = 5,
399396
)
400397

401398
rabbitmq_integration_suite(
@@ -421,17 +418,6 @@ rabbitmq_integration_suite(
421418
size = "medium",
422419
)
423420

424-
rabbitmq_integration_suite(
425-
name = "dynamic_ha_SUITE",
426-
size = "large",
427-
flaky = True,
428-
shard_count = 20,
429-
sharding_method = "case",
430-
deps = [
431-
"@proper//:erlang_app",
432-
],
433-
)
434-
435421
rabbitmq_integration_suite(
436422
name = "dynamic_qq_SUITE",
437423
size = "large",
@@ -443,18 +429,6 @@ rabbitmq_integration_suite(
443429
],
444430
)
445431

446-
rabbitmq_integration_suite(
447-
name = "eager_sync_SUITE",
448-
size = "large",
449-
additional_beam = [
450-
":sync_detection_SUITE_beam_files",
451-
],
452-
flaky = True,
453-
shard_count = 5,
454-
sharding_method = "case",
455-
tags = ["classic-queue"],
456-
)
457-
458432
rabbitmq_integration_suite(
459433
name = "feature_flags_SUITE",
460434
size = "large",
@@ -522,15 +496,6 @@ rabbitmq_integration_suite(
522496
],
523497
)
524498

525-
rabbitmq_integration_suite(
526-
name = "many_node_ha_SUITE",
527-
size = "medium",
528-
additional_beam = [
529-
":test_rabbit_ha_test_consumer_beam",
530-
":test_rabbit_ha_test_producer_beam",
531-
],
532-
)
533-
534499
rabbitmq_integration_suite(
535500
name = "rabbit_message_interceptor_SUITE",
536501
size = "medium",
@@ -672,7 +637,7 @@ rabbitmq_integration_suite(
672637
rabbitmq_integration_suite(
673638
name = "queue_master_location_SUITE",
674639
size = "large",
675-
shard_count = 3,
640+
shard_count = 2,
676641
)
677642

678643
rabbitmq_integration_suite(
@@ -681,7 +646,7 @@ rabbitmq_integration_suite(
681646
additional_beam = [
682647
":test_queue_utils_beam",
683648
],
684-
shard_count = 6,
649+
shard_count = 5,
685650
)
686651

687652
rabbitmq_integration_suite(
@@ -862,16 +827,6 @@ rabbitmq_integration_suite(
862827
size = "medium",
863828
)
864829

865-
rabbitmq_integration_suite(
866-
name = "simple_ha_SUITE",
867-
size = "large",
868-
additional_beam = [
869-
":test_rabbit_ha_test_consumer_beam",
870-
":test_rabbit_ha_test_producer_beam",
871-
],
872-
shard_count = 4,
873-
)
874-
875830
rabbitmq_integration_suite(
876831
name = "single_active_consumer_SUITE",
877832
size = "medium",
@@ -880,11 +835,6 @@ rabbitmq_integration_suite(
880835
],
881836
)
882837

883-
rabbitmq_integration_suite(
884-
name = "sync_detection_SUITE",
885-
size = "medium",
886-
)
887-
888838
rabbitmq_integration_suite(
889839
name = "term_to_binary_compat_prop_SUITE",
890840
deps = [
@@ -1001,15 +951,6 @@ rabbitmq_integration_suite(
1001951
size = "medium",
1002952
)
1003953

1004-
rabbitmq_suite(
1005-
name = "unit_gm_SUITE",
1006-
size = "small",
1007-
deps = [
1008-
"//deps/rabbitmq_ct_helpers:erlang_app",
1009-
"@meck//:erlang_app",
1010-
],
1011-
)
1012-
1013954
rabbitmq_integration_suite(
1014955
name = "unit_log_management_SUITE",
1015956
size = "medium",
@@ -1090,22 +1031,6 @@ rabbitmq_integration_suite(
10901031
],
10911032
)
10921033

1093-
rabbitmq_suite(
1094-
name = "unit_classic_mirrored_queue_sync_throttling_SUITE",
1095-
size = "small",
1096-
deps = [
1097-
"//deps/rabbit_common:erlang_app",
1098-
],
1099-
)
1100-
1101-
rabbitmq_suite(
1102-
name = "unit_classic_mirrored_queue_throughput_SUITE",
1103-
size = "small",
1104-
deps = [
1105-
"//deps/rabbit_common:erlang_app",
1106-
],
1107-
)
1108-
11091034
rabbitmq_integration_suite(
11101035
name = "direct_exchange_routing_v2_SUITE",
11111036
size = "medium",
@@ -1315,8 +1240,6 @@ eunit(
13151240
":test_rabbit_auth_backend_context_propagation_mock_beam",
13161241
":test_rabbit_dummy_protocol_connection_info_beam",
13171242
":test_rabbit_foo_protocol_connection_info_beam",
1318-
":test_rabbit_ha_test_consumer_beam",
1319-
":test_rabbit_ha_test_producer_beam",
13201243
":test_test_util_beam",
13211244
":test_test_rabbit_event_handler_beam",
13221245
":test_clustering_utils_beam",

deps/rabbit/Makefile

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -67,9 +67,6 @@ define PROJECT_ENV
6767
{ssl_apps, [asn1, crypto, public_key, ssl]},
6868
%% classic queue storage implementation version
6969
{classic_queue_default_version, 2},
70-
%% see rabbitmq-server#114
71-
{mirroring_flow_control, true},
72-
{mirroring_sync_batch_size, 4096},
7370
%% see rabbitmq-server#227 and related tickets.
7471
%% msg_store_credit_disc_bound only takes effect when
7572
%% messages are persisted to the message store. If messages

0 commit comments

Comments
 (0)