Skip to content

Commit cf3d921

Browse files
committed
Make plugin compatible with 3.12
due to rabbitmq/rabbitmq-server#6821
1 parent 07af0c0 commit cf3d921

File tree

3 files changed

+6
-7
lines changed

3 files changed

+6
-7
lines changed

Makefile

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
11
PROJECT = rabbitmq_lvc_exchange
22
PROJECT_DESCRIPTION = RabbitMQ Last Value Cache exchange
33

4-
RABBITMQ_VERSION ?= v3.11.x
4+
RABBITMQ_VERSION ?= v3.12.x
55
current_rmq_ref = $(RABBITMQ_VERSION)
66

77
define PROJECT_APP_EXTRA_KEYS
8-
{broker_version_requirements, ["3.11.0"]}
8+
{broker_version_requirements, ["3.12.0"]}
99
endef
1010

1111
dep_amqp_client = git_rmq-subfolder rabbitmq-erlang-client $(RABBITMQ_VERSION)

README.md

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,11 @@ binding key.
1616

1717
## Supported RabbitMQ Versions
1818

19-
The most recent release of this plugin targets RabbitMQ 3.11.x.
20-
Release series earlier than 3.9 are [out of support](https://www.rabbitmq.com/versions.html).
19+
The most recent release of this plugin targets RabbitMQ 3.12.x.
2120

2221
## Supported Erlang/OTP Versions
2322

24-
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.
23+
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.
2524

2625
## Installation
2726

src/rabbit_exchange_type_lvc.erl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ route(#exchange{name = Name},
3232
CC when is_list(CC) -> CC;
3333
To -> [To]
3434
end,
35-
rabbit_misc:execute_mnesia_transaction(
35+
rabbit_mnesia:execute_mnesia_transaction(
3636
fun () ->
3737
[mnesia:write(?LVC_TABLE,
3838
#cached{key = #cachekey{exchange=Name,
@@ -85,7 +85,7 @@ add_binding(none, #exchange{ name = XName },
8585
[#cached{content = Msg}] ->
8686
Delivery = rabbit_basic:delivery(
8787
false, false, Msg, undefined),
88-
Qs = rabbit_amqqueue:lookup(
88+
Qs = rabbit_amqqueue:lookup_many(
8989
rabbit_exchange:route(E, Delivery)),
9090
rabbit_amqqueue:deliver(Qs, Delivery)
9191
end

0 commit comments

Comments
 (0)