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 8
8
-module (rabbit_db_queue ).
9
9
10
10
-include_lib (" kernel/include/logger.hrl" ).
11
- -include_lib (" stdlib/include/assert.hrl" ).
12
11
-include_lib (" stdlib/include/qlc.hrl" ).
13
12
14
13
-include_lib (" khepri/include/khepri.hrl" ).
@@ -897,7 +896,7 @@ set_many_in_mnesia(Qs) ->
897
896
mnesia :transaction (
898
897
fun () ->
899
898
[begin
900
- ? assert ( amqqueue :is_durable (Q ) ),
899
+ true = amqqueue :is_durable (Q ),
901
900
ok = mnesia :write (? MNESIA_DURABLE_TABLE , Q , write )
902
901
end || Q <- Qs ],
903
902
ok
@@ -908,7 +907,7 @@ set_many_in_khepri(Qs) ->
908
907
rabbit_khepri :transaction (
909
908
fun () ->
910
909
[begin
911
- ? assert ( amqqueue :is_durable (Q ) ),
910
+ true = amqqueue :is_durable (Q ),
912
911
Path = khepri_queue_path (amqqueue :get_name (Q )),
913
912
case khepri_tx :put (Path , Q ) of
914
913
ok -> ok ;
You can’t perform that action at this time.
0 commit comments