diff options
author | Michael Klishin <michael@clojurewerkz.org> | 2021-02-24 22:37:26 +0300 |
---|---|---|
committer | Michael Klishin <michael@clojurewerkz.org> | 2021-02-24 22:37:55 +0300 |
commit | 046db4be92c6789affcc168512a5b053259eaa32 (patch) | |
tree | d25bba37f71bed4dd4f3757f4d29e97eccaded45 | |
parent | 71c3eec5065ea7934ecd6d5d95912aa51f04dc31 (diff) | |
download | rabbitmq-server-git-046db4be92c6789affcc168512a5b053259eaa32.tar.gz |
OTP 22 compatibility
(cherry picked from commit 652ffd2a1597aa16dc92009edf92114e22f4aee7)
-rw-r--r-- | deps/rabbit/src/pid_recomposition.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/deps/rabbit/src/pid_recomposition.erl b/deps/rabbit/src/pid_recomposition.erl index e13c66a6af..b9a364476f 100644 --- a/deps/rabbit/src/pid_recomposition.erl +++ b/deps/rabbit/src/pid_recomposition.erl @@ -41,7 +41,7 @@ from_binary(Bin) -> end, <<ID:32/integer, Serial:32/integer, Creation:32/integer>> = Rest2, #{ - node => binary_to_atom(Node), + node => binary_to_atom(Node, utf8), id => ID, serial => Serial, creation => Creation @@ -49,7 +49,7 @@ from_binary(Bin) -> -spec to_binary(#{atom() => any()}) -> binary(). to_binary(#{node := Node, id := ID, serial := Serial, creation := Creation}) -> - BinNode = atom_to_binary(Node), + BinNode = atom_to_binary(Node, utf8), NodeLen = byte_size(BinNode), <<?TTB_PREFIX:8/unsigned, ?NEW_PID_EXT:8/unsigned, ?ATOM_UTF8_EXT:8/unsigned, NodeLen:16/unsigned, BinNode/binary, ID:32, Serial:32, Creation:32>>. |