diff --git a/src/lavinmq/amqp/queue/queue.cr b/src/lavinmq/amqp/queue/queue.cr
index a2ea10eea4..0a989de779 100644
--- a/src/lavinmq/amqp/queue/queue.cr
+++ b/src/lavinmq/amqp/queue/queue.cr
@@ -50,6 +50,7 @@ module LavinMQ::AMQP
     getter consumer_timeout : UInt64? = Config.instance.consumer_timeout
 
     @consumers_empty_change = ::Channel(Bool).new
+    @queue_expiration_ttl_change = ::Channel(Nil).new
 
     private def queue_expire_loop
       loop do
@@ -336,19 +337,6 @@ module LavinMQ::AMQP
       File.delete(File.join(@data_dir, ".paused"))
     end
 
-    @queue_expiration_ttl_change = ::Channel(Nil).new
-
-    private def queue_expiration_ttl : Time::Span?
-      if e = @expires
-        expires_in = e.milliseconds
-        if expires_in > Time::Span.zero
-          expires_in
-        else
-          Time::Span.zero
-        end
-      end
-    end
-
     def close : Bool
       return false if @closed
       @closed = true