Skip to content

Commit b5ad5c2

Browse files
committed
Follow AMQP spec for durable field
1 parent 4f1076d commit b5ad5c2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

deps/rabbit/src/mc_amqp.erl

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -259,10 +259,10 @@ get_property(durable, Msg) ->
259259
_ ->
260260
%% fallback in case the source protocol was old AMQP 0.9.1
261261
case message_annotation(<<"x-basic-delivery-mode">>, Msg, undefined) of
262-
{ubyte, 1} ->
263-
false;
262+
{ubyte, 2} ->
263+
true;
264264
_ ->
265-
true
265+
false
266266
end
267267
end;
268268
get_property(timestamp, Msg) ->

0 commit comments

Comments
 (0)