Skip to content

Commit e42c1b7

Browse files
committed
Fix compile-time warnings
Signed-off-by: Matteo Cafasso <[email protected]>
1 parent d3a9cd8 commit e42c1b7

File tree

3 files changed

+4
-4
lines changed

3 files changed

+4
-4
lines changed

lib/rabbitmq_message_deduplication/cache.ex

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,7 @@ defmodule RabbitMQMessageDeduplication.Cache do
2121
alias :mnesia, as: Mnesia
2222

2323
@options [:size, :ttl, :distributed, :limit, :default_ttl]
24-
@cache_wait_time Application.get_env(:rabbitmq_message_deduplication, :cache_wait_time)
24+
@cache_wait_time Application.compile_env(:rabbitmq_message_deduplication, :cache_wait_time)
2525

2626
@doc """
2727
Create a new cache with the given name and options.

lib/rabbitmq_message_deduplication/cache_manager.ex

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,8 +31,8 @@ defmodule RabbitMQMessageDeduplication.CacheManager do
3131
enables: :external_infrastructure]}
3232

3333
@caches :message_deduplication_caches
34-
@cache_wait_time Application.get_env(:rabbitmq_message_deduplication, :cache_wait_time)
35-
@cleanup_period Application.get_env(:rabbitmq_message_deduplication, :cache_cleanup_period)
34+
@cache_wait_time Application.compile_env(:rabbitmq_message_deduplication, :cache_wait_time)
35+
@cleanup_period Application.compile_env(:rabbitmq_message_deduplication, :cache_cleanup_period)
3636

3737
def start_link() do
3838
GenServer.start_link(__MODULE__, %{}, name: __MODULE__)

lib/rabbitmq_message_deduplication/rabbit_message_deduplication_queue.ex

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -460,7 +460,7 @@ defmodule RabbitMQMessageDeduplication.Queue do
460460
passthrough do: zip_msgs_and_acks(delivered_publish, acks, acc, qs)
461461
end
462462

463-
@impl :rabbit_backing_queue
463+
# Not present anymore in recent versions of RMQ, keeping for old ones
464464
def handle_info(term, state = dqstate(queue_state: qs)) do
465465
passthrough1(state, do: set_queue_mode(term, qs))
466466
end

0 commit comments

Comments
 (0)