From fb19293313e15605b4ac7c289f39e06ccaf1ff2a Mon Sep 17 00:00:00 2001 From: bedrock-adam Date: Sat, 10 Aug 2024 14:53:10 +1000 Subject: [PATCH] remove code --- lib/outboxer/publisher.rb | 23 ----------------------- 1 file changed, 23 deletions(-) diff --git a/lib/outboxer/publisher.rb b/lib/outboxer/publisher.rb index 4b03652f..e1ce232d 100644 --- a/lib/outboxer/publisher.rb +++ b/lib/outboxer/publisher.rb @@ -34,29 +34,6 @@ def stop @publishing = false end - def create_delete_published_messages_thread( - cleanup_interval: 60, retention_period: 3600, - logger: Logger.new($stdout, level: Logger::INFO), kernel: Kernel, time: Time - ) - Thread.new do - loop do - begin - Messages.delete_all( - status: Models::Message::Status::PUBLISHED, - batch_size: 100, - older_than: time.now.utc - retention_period) - - kernel.sleep(cleanup_interval) - rescue StandardError => exception - logger.error "#{exception.class}: #{exception.message}" - exception.backtrace.each { |frame| logger.error frame } - - kernel.sleep(cleanup_interval) - end - end - end - end - def create_publisher_thread(queue:, logger:, &block) Thread.new do loop do