diff options
| -rw-r--r-- | src/rabbit_basic.erl | 4 | ||||
| -rw-r--r-- | src/rabbit_channel.erl | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/rabbit_basic.erl b/src/rabbit_basic.erl index 3bf0897b..4ab7a2a0 100644 --- a/src/rabbit_basic.erl +++ b/src/rabbit_basic.erl @@ -100,12 +100,12 @@ message(ExchangeName, RoutingKeyBin, RawProperties, BodyBin) -> case is_message_persistent(Content) of {invalid, Other} -> {error, {invalid_delivery_mode, Other}}; - Boolean when is_boolean(Boolean) -> + IsPersistent when is_boolean(IsPersistent) -> #basic_message{exchange_name = ExchangeName, routing_key = RoutingKeyBin, content = Content, guid = rabbit_guid:guid(), - is_persistent = Boolean} + is_persistent = IsPersistent} end. properties(P = #'P_basic'{}) -> diff --git a/src/rabbit_channel.erl b/src/rabbit_channel.erl index a96af292..9aeb4623 100644 --- a/src/rabbit_channel.erl +++ b/src/rabbit_channel.erl @@ -1018,8 +1018,8 @@ is_message_persistent(Content) -> "treating as 1, non-persistent~n", [Other]), false; - Boolean when is_boolean(Boolean) -> - Boolean + IsPersistent when is_boolean(IsPersistent) -> + IsPersistent end. lock_message(true, MsgStruct, State = #ch{unacked_message_q = UAMQ}) -> |