summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAntoine Gagné <gagnantoine@gmail.com>2019-08-08 16:07:50 -0400
committerAntoine Gagné <gagnantoine@gmail.com>2019-08-08 16:07:50 -0400
commit65fac9578a238c0e40da1690f309aa830f44b2e1 (patch)
treeb4241a8da528c4ed4c81ec4c60f45592c74cc7cd
parent3c0c50b762d3b4d7d079c72002f14e159a84d023 (diff)
downloadrabbitmq-server-git-65fac9578a238c0e40da1690f309aa830f44b2e1.tar.gz
Add working properties
-rw-r--r--deps/amqp10_client/src/amqp10_client_session.erl10
1 files changed, 1 insertions, 9 deletions
diff --git a/deps/amqp10_client/src/amqp10_client_session.erl b/deps/amqp10_client/src/amqp10_client_session.erl
index 060c605dc7..f433aff31d 100644
--- a/deps/amqp10_client/src/amqp10_client_session.erl
+++ b/deps/amqp10_client/src/amqp10_client_session.erl
@@ -666,15 +666,7 @@ translate_properties(Properties) when is_map(Properties) ->
{map, maps:fold(fun translate_property/3, [], Properties)}.
translate_property(K, V, Acc) when is_tuple(V) ->
- io:format(user, "~nat=~s:~p:~p key=~p value=~p", [?MODULE_STRING, ?FUNCTION_NAME, ?LINE, K, V]),
- [{{symbol, K}, {described, {symbol, K}, V}} | Acc];
-translate_property(K, V, Acc) when is_binary(V) ->
- [{{symbol, K}, {described, {symbol, K}, {utf8, V}}} | Acc];
-translate_property(K, V, Acc) when is_integer(V) ->
- [{{symbol, K}, {described, {symbol, K}, {long, V}}} | Acc];
-translate_property(K, V, Acc) when is_list(V) ->
- Values = lists:map(fun(Id) -> {utf8, Id} end, V),
- [{{symbol, K}, {described, {symbol, K}, Values}} | Acc].
+ [{{symbol, K}, V} | Acc].
translate_terminus_durability(none) -> 0;
translate_terminus_durability(configuration) -> 1;