Skip to content

Commit cb41a17

Browse files
Resolve conflicts #16253 #16297 #16298
1 parent c971ba3 commit cb41a17

2 files changed

Lines changed: 2 additions & 8 deletions

File tree

deps/rabbit/Makefile

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -272,11 +272,7 @@ PARALLEL_CT_SET_4_B = per_user_connection_tracking per_vhost_connection_limit ra
272272
PARALLEL_CT_SET_4_C = msg_size_metrics unit_msg_size_metrics per_vhost_msg_store per_vhost_queue_limit priority_queue upgrade_preparation vhost
273273
PARALLEL_CT_SET_4_D = per_user_connection_channel_tracking product_info queue_type rabbitmq_queues_cli_integration rabbitmq_streams_cli_integration rabbitmqctl_integration rabbitmqctl_shutdown routing rabbit_amqqueue
274274

275-
<<<<<<< HEAD
276-
PARALLEL_CT_SET_5_A = consumer_recheck_prop rabbit_direct_reply_to_prop prop_stream_arg_validation direct_reply_to_amqpl direct_reply_to_amqp classic_queue
277-
=======
278-
PARALLEL_CT_SET_5_A = consumer_recheck_prop pid_codec pid_codec_prop rabbit_direct_reply_to_prop rabbit_quorum_queue_prop prop_stream_arg_validation direct_reply_to_amqpl direct_reply_to_amqp classic_queue
279-
>>>>>>> 6a16321935 (Add new test suites to the parallel CT set 5A)
275+
PARALLEL_CT_SET_5_A = consumer_recheck_prop pid_codec pid_codec_prop rabbit_direct_reply_to_prop prop_stream_arg_validation direct_reply_to_amqpl direct_reply_to_amqp classic_queue
280276
PARALLEL_CT_SET_5_B = feature_flags_v2 backing_queue transactions
281277
PARALLEL_CT_SET_5_C = metadata_store_migration cluster_upgrade maintenance_mode
282278
PARALLEL_CT_SET_5_D = rabbit_fifo_dlx_integration publisher_confirms_parallel

deps/rabbit/src/rabbit_volatile_queue.erl

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -418,7 +418,6 @@ pid_from_name(<<?PREFIX, Bin/binary>>, CandidateNodes) ->
418418
pid_from_name(_, _) ->
419419
error.
420420

421-
<<<<<<< HEAD
422421
%% Returns the base 64 encoded key.
423422
-spec key_from_name(rabbit_misc:resource_name()) ->
424423
{ok, binary()} | error.
@@ -431,14 +430,13 @@ key_from_name(<<?PREFIX, Suffix/binary>>) ->
431430
end;
432431
key_from_name(_) ->
433432
error.
434-
=======
433+
435434
%% Returns the integer hash following "@" in a synthetic node-name binary
436435
%% such as <<"reply@1234567">>. Malformed input raises and is caught by
437436
%% the surrounding try.
438437
node_hash_from_binary(NodeBin) ->
439438
[_Prefix, Suffix] = binary:split(NodeBin, <<"@">>),
440439
binary_to_integer(Suffix).
441-
>>>>>>> fa3a26d20b (Refactor Direct Reply-to one more time)
442440

443441
nodes_with_hashes() ->
444442
#{erlang:phash2(Node) => Node || Node <- rabbit_nodes:list_members()}.

0 commit comments

Comments
 (0)