summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Klishin <michael@clojurewerkz.org>2021-02-24 22:37:26 +0300
committerMichael Klishin <michael@clojurewerkz.org>2021-02-24 22:37:55 +0300
commit046db4be92c6789affcc168512a5b053259eaa32 (patch)
treed25bba37f71bed4dd4f3757f4d29e97eccaded45
parent71c3eec5065ea7934ecd6d5d95912aa51f04dc31 (diff)
downloadrabbitmq-server-git-046db4be92c6789affcc168512a5b053259eaa32.tar.gz
OTP 22 compatibility
(cherry picked from commit 652ffd2a1597aa16dc92009edf92114e22f4aee7)
-rw-r--r--deps/rabbit/src/pid_recomposition.erl4
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>>.