Skip to content

Commit 3da78c6

Browse files
committed
Fix typo of Mnesia storage_type
Plugin used to crash in a distributed cluster when a node was added to the cache replicas. ``` node 'rabbit@node-02' up ** Generic server 'Elixir.RabbitMQMessageDeduplication.CacheManager' terminating ** Last message in was {mnesia_system_event, {mnesia_up,'rabbit@node-02'}} ** When Server state == #{} ** Reason for termination == ** {{case_clause, {aborted, {badarg,cache_exchange_<name>, ram_nodes}}}, [{'Elixir.RabbitMQMessageDeduplication.Cache', '-cache_rebalance/1-fun-0-',4, ```
1 parent 78b57ac commit 3da78c6

File tree

1 file changed

+2
-2
lines changed
  • lib/rabbitmq_message_deduplication

1 file changed

+2
-2
lines changed

lib/rabbitmq_message_deduplication/cache.ex

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -273,8 +273,8 @@ defmodule RabbitMQMessageDeduplication.Cache do
273273
# Returns a tuple {persistence, nodes}
274274
defp cache_layout(cache) do
275275
case Mnesia.table_info(cache, :ram_copies) do
276-
[] -> {:disc_nodes, Mnesia.table_info(cache, :disc_copies)}
277-
nodes -> {:ram_nodes, nodes}
276+
[] -> {:disc_copies, Mnesia.table_info(cache, :disc_copies)}
277+
nodes -> {:ram_copies, nodes}
278278
end
279279
end
280280

0 commit comments

Comments
 (0)