Make plugin compatible with 3.12

due to rabbitmq/rabbitmq-server#6821
rabbitmq · May 31, 2023 · cf3d921 · cf3d921
1 parent 07af0c0
commit cf3d921
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 7 deletions.
diff --git a/Makefile b/Makefile
@@ -1,11 +1,11 @@
 PROJECT = rabbitmq_lvc_exchange
 PROJECT_DESCRIPTION = RabbitMQ Last Value Cache exchange
 
-RABBITMQ_VERSION ?= v3.11.x
+RABBITMQ_VERSION ?= v3.12.x
 current_rmq_ref = $(RABBITMQ_VERSION)
 
 define PROJECT_APP_EXTRA_KEYS
-	{broker_version_requirements, ["3.11.0"]}
+	{broker_version_requirements, ["3.12.0"]}
 endef
 
 dep_amqp_client                = git_rmq-subfolder rabbitmq-erlang-client $(RABBITMQ_VERSION)

diff --git a/README.md b/README.md
@@ -16,12 +16,11 @@ binding key.
 
 ## Supported RabbitMQ Versions
 
-The most recent release of this plugin targets RabbitMQ 3.11.x.
-Release series earlier than 3.9 are [out of support](https://www.rabbitmq.com/versions.html).
+The most recent release of this plugin targets RabbitMQ 3.12.x.
 
 ## Supported Erlang/OTP Versions
 
-Latest version of this plugin [requires Erlang 25.0 or later versions](https://www.rabbitmq.com/which-erlang.html), same as RabbitMQ 3.11.x.
+Latest version of this plugin [requires Erlang 25.0 or later versions](https://www.rabbitmq.com/which-erlang.html), same as RabbitMQ 3.12.x.
 
 ## Installation
 

diff --git a/src/rabbit_exchange_type_lvc.erl b/src/rabbit_exchange_type_lvc.erl
@@ -32,7 +32,7 @@ route(#exchange{name = Name},
                CC when is_list(CC) -> CC;
                To                 -> [To]
            end,
-    rabbit_misc:execute_mnesia_transaction(
+    rabbit_mnesia:execute_mnesia_transaction(
       fun () ->
               [mnesia:write(?LVC_TABLE,
                             #cached{key = #cachekey{exchange=Name,
@@ -85,7 +85,7 @@ add_binding(none, #exchange{ name = XName },
                     [#cached{content = Msg}] ->
                         Delivery = rabbit_basic:delivery(
                           false, false, Msg, undefined),
-                        Qs = rabbit_amqqueue:lookup(
+                        Qs = rabbit_amqqueue:lookup_many(
                           rabbit_exchange:route(E, Delivery)),
                         rabbit_amqqueue:deliver(Qs, Delivery)
                 end