root
/
rabbitmq-server
mirror of https://github.com/rabbitmq/rabbitmq-server.git
1
0
Fork 0
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Test Unicode char in queue names

This commit is contained in:
David Ansari 2022-12-16 11:47:14 +00:00 committed by Luke Bakken
parent 8f0800e578
commit b0d03081fb
No known key found for this signature in database
GPG Key ID: D99DE30E43EAE440
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
deps/rabbit/test/unicode_SUITE.erl vendored
View File

@ -6,6 +6,9 @@
-compile(export_all). -compile(export_all).
%% Unicode U+1F407
-define(UNICODE_STRING, "bunny🐇bunny").
all() -> all() ->
[ [
{group, queues} {group, queues}
@ -34,8 +37,7 @@ end_per_suite(Config) ->
init_per_group(Group, Config0) -> init_per_group(Group, Config0) ->
PrivDir0 = ?config(priv_dir, Config0), PrivDir0 = ?config(priv_dir, Config0),
%% Put unicode char U+1F407 in directory name PrivDir = filename:join(PrivDir0, ?UNICODE_STRING),
PrivDir = filename:join(PrivDir0, "bunny🐇bunny"),
ok = file:make_dir(PrivDir), ok = file:make_dir(PrivDir),
Config = rabbit_ct_helpers:set_config(Config0, [{priv_dir, PrivDir}, Config = rabbit_ct_helpers:set_config(Config0, [{priv_dir, PrivDir},
{rmq_nodename_suffix, Group}]), {rmq_nodename_suffix, Group}]),
@ -69,7 +71,8 @@ quorum_queue(Config) ->
ok = queue(Config, ?FUNCTION_NAME, [{<<"x-queue-type">>, longstr, <<"quorum">>}]). ok = queue(Config, ?FUNCTION_NAME, [{<<"x-queue-type">>, longstr, <<"quorum">>}]).
queue(Config, QName0, Args) -> queue(Config, QName0, Args) ->
QName = rabbit_data_coercion:to_binary(QName0), QName1 = rabbit_data_coercion:to_binary(QName0),
QName = <<QName1/binary, ?UNICODE_STRING/utf8>>,
Server = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename), Server = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename),
Ch = rabbit_ct_client_helpers:open_channel(Config, Server), Ch = rabbit_ct_client_helpers:open_channel(Config, Server),
amqp_channel:call(Ch, #'queue.declare'{queue = QName, amqp_channel:call(Ch, #'queue.declare'{queue = QName,
@ -85,7 +88,8 @@ queue(Config, QName0, Args) ->
stream(Config) -> stream(Config) ->
ok = rabbit_ct_broker_helpers:enable_feature_flag(Config, stream_queue), ok = rabbit_ct_broker_helpers:enable_feature_flag(Config, stream_queue),
Server = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename), Server = rabbit_ct_broker_helpers:get_node_config(Config, 0, nodename),
ConsumerTag = QName = atom_to_binary(?FUNCTION_NAME), ConsumerTag = QName0 = atom_to_binary(?FUNCTION_NAME),
QName = <<QName0/binary, ?UNICODE_STRING/utf8>>,
Ch = rabbit_ct_client_helpers:open_channel(Config, Server), Ch = rabbit_ct_client_helpers:open_channel(Config, Server),
amqp_channel:call(Ch, #'queue.declare'{queue = QName, amqp_channel:call(Ch, #'queue.declare'{queue = QName,
durable = true, durable = true,