File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change 88-module (rabbit_db_queue ).
99
1010-include_lib (" kernel/include/logger.hrl" ).
11- -include_lib (" stdlib/include/assert.hrl" ).
1211-include_lib (" stdlib/include/qlc.hrl" ).
1312
1413-include_lib (" khepri/include/khepri.hrl" ).
@@ -897,7 +896,7 @@ set_many_in_mnesia(Qs) ->
897896 mnesia :transaction (
898897 fun () ->
899898 [begin
900- ? assert ( amqqueue :is_durable (Q ) ),
899+ true = amqqueue :is_durable (Q ),
901900 ok = mnesia :write (? MNESIA_DURABLE_TABLE , Q , write )
902901 end || Q <- Qs ],
903902 ok
@@ -908,7 +907,7 @@ set_many_in_khepri(Qs) ->
908907 rabbit_khepri :transaction (
909908 fun () ->
910909 [begin
911- ? assert ( amqqueue :is_durable (Q ) ),
910+ true = amqqueue :is_durable (Q ),
912911 Path = khepri_queue_path (amqqueue :get_name (Q )),
913912 case khepri_tx :put (Path , Q ) of
914913 ok -> ok ;
You can’t perform that action at this time.
0 commit comments