diff options
| author | Lajos Gerecs <lajos.gerecs@erlang-solutions.com> | 2022-06-12 17:41:48 +0200 |
|---|---|---|
| committer | Lajos Gerecs <lajos.gerecs@erlang-solutions.com> | 2022-06-12 17:41:48 +0200 |
| commit | 58c7486e48f5601e6cc1c00878077deb157d0271 (patch) | |
| tree | c43eaf8b1993dd3ad040e789ae24025b0ddbe54e | |
| parent | 993abcda0125ace42d47766fe1edbcc7591685fb (diff) | |
| download | rabbitmq-server-git-58c7486e48f5601e6cc1c00878077deb157d0271.tar.gz | |
fix formatting
| -rw-r--r-- | deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_message.erl | 28 |
1 files changed, 14 insertions, 14 deletions
diff --git a/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_message.erl b/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_message.erl index 0f6b8c549b..2ab8806558 100644 --- a/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_message.erl +++ b/deps/rabbitmq_amqp1_0/src/rabbit_amqp1_0_message.erl @@ -62,11 +62,11 @@ assemble(app_properties, {R, P = #'P_basic'{headers = Headers}, C}, {#'v1_0.application_properties'{}, Rest}, Uneaten) -> AppPropsBin = chunk(Rest, Uneaten), Amqp091Headers = case ?CONVERT_APP_PROPS_TO_AMQP091_HEADERS of - true -> - amqp10_app_props_to_amqp091_headers(Headers, AppPropsBin); - _ -> - Headers - end, + true -> + amqp10_app_props_to_amqp091_headers(Headers, AppPropsBin); + _ -> + Headers + end, AppPropsAdded = set_header( ?APP_PROPERTIES_HEADER, AppPropsBin, Amqp091Headers), @@ -311,15 +311,15 @@ amqp10_app_props_to_amqp091_headers(CurrentHeaders, AppPropsBin) -> Headers -> Headers end, lists:foldl(fun(Prop, Acc) -> - case Prop of - {{utf8, Key}, {ValueType, Value}} -> - case type10_to_type091(Key, ValueType, Value) of - undefined -> Acc; - Typed -> [Typed |Acc] - end; - _ -> Acc - end - end, Hs, AppProps); + case Prop of + {{utf8, Key}, {ValueType, Value}} -> + case type10_to_type091(Key, ValueType, Value) of + undefined -> Acc; + Typed -> [Typed |Acc] + end; + _ -> Acc + end + end, Hs, AppProps); _ -> CurrentHeaders end. type10_to_type091(Key, Type, Value) -> |
