does_api_comply_with

Author: dumbbell

deps/rabbit/src/rabbit_db_queue.erl

@@ -412,7 +412,7 @@ delete_in_khepri(QueueName, OnlyDurable) ->
       fun () ->
               Path = khepri_queue_path(QueueName),
               UsesUniformWriteRet = try
-                                        khepri_tx:api_uses(uniform_write_ret)
+                                        khepri_tx:does_api_comply_with(uniform_write_ret)
                                     catch
                                         error:undef ->
                                             false
@@ -1153,7 +1153,7 @@ do_delete_transient_queues_in_khepri_tx([{Path, Vsn, QName} | Rest], Acc) ->
     VersionedPath = khepri_path:combine_with_conditions(
                       Path, [#if_payload_version{version = Vsn}]),
     UsesUniformWriteRet = try
-                              khepri_tx:api_uses(uniform_write_ret)
+                              khepri_tx:does_api_comply_with(uniform_write_ret)
                           catch
                               error:undef ->
                                   false

deps/rabbit/src/rabbit_db_rtparams.erl

@@ -114,7 +114,7 @@ set_in_khepri_tx(Key, Term) ->
     Record = #runtime_parameters{key   = Key,
                                  value = Term},
     UsesUniformWriteRet = try
-                              khepri_tx:api_uses(uniform_write_ret)
+                              khepri_tx:does_api_comply_with(uniform_write_ret)
                           catch
                               error:undef ->
                                   false