diff --git a/src/lavinmq/amqp/queue/delayed_exchange_queue.cr b/src/lavinmq/amqp/queue/delayed_exchange_queue.cr index 286e17df2e..07a2041716 100644 --- a/src/lavinmq/amqp/queue/delayed_exchange_queue.cr +++ b/src/lavinmq/amqp/queue/delayed_exchange_queue.cr @@ -1,5 +1,4 @@ -"./queue" -require "./durable_queue" +require "./queue" module LavinMQ::AMQP class DelayedExchangeQueue < Queue diff --git a/src/lavinmq/amqp/queue/message_store.cr b/src/lavinmq/amqp/queue/message_store.cr index 835178535c..809b240713 100644 --- a/src/lavinmq/amqp/queue/message_store.cr +++ b/src/lavinmq/amqp/queue/message_store.cr @@ -422,7 +422,6 @@ module LavinMQ end mfile.delete(raise_on_missing: false).close @replicator.try &.delete_file(mfile.path) - true end Fiber.yield end diff --git a/src/lavinmq/etcd.cr b/src/lavinmq/etcd.cr index c585325342..dbfdb45ae9 100644 --- a/src/lavinmq/etcd.cr +++ b/src/lavinmq/etcd.cr @@ -66,7 +66,6 @@ module LavinMQ def lease_revoke(id) : Nil post("/v3/lease/revoke", body: %({"ID":"#{id}"})) - true end # Leader election campaign