From cbd08d40da47ea1e933e912948000442b38f99bd Mon Sep 17 00:00:00 2001 From: Magnus Landerblom Date: Tue, 26 Nov 2024 20:40:00 +0100 Subject: [PATCH] move files around --- spec/deduper_spec.cr | 2 +- src/lavinmq/amqp/queue/queue.cr | 1 + src/lavinmq/{exchange/dedup_ext.cr => deduplication.cr} | 0 src/lavinmq/exchange/exchange.cr | 1 + 4 files changed, 3 insertions(+), 1 deletion(-) rename src/lavinmq/{exchange/dedup_ext.cr => deduplication.cr} (100%) diff --git a/spec/deduper_spec.cr b/spec/deduper_spec.cr index fbdaf3c88f..0c4769de69 100644 --- a/spec/deduper_spec.cr +++ b/spec/deduper_spec.cr @@ -1,5 +1,5 @@ require "./spec_helper" -require "../src/lavinmq/exchange/dedup_ext.cr" +require "../src/lavinmq/deduplication.cr" describe LavinMQ::Deduplication do describe LavinMQ::Deduplication::MemoryCache do diff --git a/src/lavinmq/amqp/queue/queue.cr b/src/lavinmq/amqp/queue/queue.cr index 72d8162e2b..705fa1a56c 100644 --- a/src/lavinmq/amqp/queue/queue.cr +++ b/src/lavinmq/amqp/queue/queue.cr @@ -13,6 +13,7 @@ require "./state" require "./event" require "./message_store" require "../../unacked_message" +require "../../deduplication" module LavinMQ::AMQP class Queue < LavinMQ::Queue diff --git a/src/lavinmq/exchange/dedup_ext.cr b/src/lavinmq/deduplication.cr similarity index 100% rename from src/lavinmq/exchange/dedup_ext.cr rename to src/lavinmq/deduplication.cr diff --git a/src/lavinmq/exchange/exchange.cr b/src/lavinmq/exchange/exchange.cr index 6a72cca854..4cf080b5e4 100644 --- a/src/lavinmq/exchange/exchange.cr +++ b/src/lavinmq/exchange/exchange.cr @@ -5,6 +5,7 @@ require "../sortable_json" require "../observable" require "./event" require "../amqp/queue" +require "../deduplication" module LavinMQ alias Destination = Queue | Exchange