File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
rabbitmq_consistent_hash_exchange Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -326,9 +326,9 @@ khepri_delete(Path) ->
326
326
mnesia_write_to_khepri (? TABLE , Specs ) ->
327
327
rabbit_khepri :transaction (
328
328
fun () ->
329
- [khepri_create_tx (khepri_mirrored_supervisor_path (Group , Id ),
329
+ [khepri_create_tx (khepri_mirrored_supervisor_path (Group , SimpleId ),
330
330
Spec )
331
- || # mirrored_sup_childspec {key = {Group , Id }} = Spec <- Specs ]
331
+ || # mirrored_sup_childspec {key = {Group , { SimpleId , _ } }} = Spec <- Specs ]
332
332
end , rw ).
333
333
334
334
mnesia_delete_to_khepri (? TABLE , # mirrored_sup_childspec {key = {Group , Id }}) ->
Original file line number Diff line number Diff line change @@ -58,7 +58,7 @@ broker_for_integration_suites()
58
58
59
59
rabbitmq_integration_suite (
60
60
name = "rabbit_exchange_type_consistent_hash_SUITE" ,
61
- shard_count = 3 ,
61
+ shard_count = 7 ,
62
62
)
63
63
64
64
assert_suites ()
You can’t perform that action at this time.
0 commit comments