anchor.diff:  shard_basic_consume_interceptor_test() ->
       with_ch(
         fun (Ch) ->
  -              Sh = <<"sharding.test">>,
  +              Sh = ?TEST_X,
                 exchange_op(Ch, x_declare(Sh)),
                 set_param("sharding-definition", "three",
                           "{\"shards-per-node\": 3}"),
  
positive.code: shard_queue_creation_test() ->
      with_ch(
        fun (Ch) ->
                exchange_op(Ch, x_declare(<<"sharding.test">>)),
                set_param("sharding-definition", "3_shard",
                          "{\"shards-per-node\": 3}"),
                set_pol("3_shard", "^sharding\\.", policy("3_shard")),
                ?assertEqual(3, length(queues("rabbit-test"))),
  
                teardown(Ch,
                         [{<<"sharding.test">>, 3}],
                         [{"sharding-definition", "3_shard"}],
                         ["3_shard"])
        end).
  
negative.code: shard_decrease_spn_keep_queues_test() ->
      with_ch(
        fun (Ch) ->
                exchange_op(Ch, x_declare(?TEST_X)),
                set_param("sharding-definition", "5_shard",
                          "{\"shards-per-node\": 5}"),
                set_pol("5_shard", "^sharding\\.", policy("5_shard")),
  