Skip to content

Commit

Permalink
Readded require so to_prepare could be removed
Browse files Browse the repository at this point in the history
  • Loading branch information
AKeyframe committed Sep 18, 2024
1 parent a457bbe commit 8eda7c8
Show file tree
Hide file tree
Showing 2 changed files with 23 additions and 24 deletions.
4 changes: 2 additions & 2 deletions config/application.rb
Original file line number Diff line number Diff line change
Expand Up @@ -150,15 +150,15 @@ class Application < Rails::Application
end

# A collapse statement will remove the need for a namespace based on the direcotry given.
# Tasks::Support::ModuleOrClassName becomes ModuleOrClassName with the last two statements.
# Tasks::Support::ModuleOrClassName becomes ModuleOrClassName with the two statements below.
Rails.autoloaders.main.collapse(
"app/jobs/middleware",
"#{root}/lib/tasks",
"#{root}/lib/tasks/support"
)

# Will not autoload any files within directories added here
Rails.autoloaders.main.ignore(
"app/jobs/middleware",
"#{root}/lib/assets",
"#{root}/lib/pdfs",
"#{root}/lib/scripts"
Expand Down
43 changes: 21 additions & 22 deletions config/initializers/shoryuken.rb
Original file line number Diff line number Diff line change
@@ -1,31 +1,30 @@

require "#{Rails.root}/app/jobs/middleware/job_metrics_service_metric_middleware"


Rails.application.reloader.to_prepare do
# set up default exponential backoff parameters
ActiveJob::QueueAdapters::ShoryukenAdapter::JobWrapper
.shoryuken_options(auto_visibility_timeout: true,
retry_intervals: [5.seconds, 5.minutes, rand(4..8).hours])
# set up default exponential backoff parameters
ActiveJob::QueueAdapters::ShoryukenAdapter::JobWrapper
.shoryuken_options(auto_visibility_timeout: true,
retry_intervals: [5.seconds, 5.minutes, rand(4..8).hours])

if Rails.application.config.sqs_endpoint
# override the sqs_endpoint
Shoryuken::Client.sqs.config[:endpoint] = URI(Rails.application.config.sqs_endpoint)
end
if Rails.application.config.sqs_endpoint
# override the sqs_endpoint
Shoryuken::Client.sqs.config[:endpoint] = URI(Rails.application.config.sqs_endpoint)
end

if Rails.application.config.sqs_create_queues
# create the development queues
Shoryuken::Client.sqs.create_queue(queue_name: ActiveJob::Base.queue_name_prefix + "_low_priority")
Shoryuken::Client.sqs.create_queue(queue_name: ActiveJob::Base.queue_name_prefix + "_med_priority")
Shoryuken::Client.sqs.create_queue(queue_name: ActiveJob::Base.queue_name_prefix + "_high_priority")
end
if Rails.application.config.sqs_create_queues
# create the development queues
Shoryuken::Client.sqs.create_queue(queue_name: ActiveJob::Base.queue_name_prefix + "_low_priority")
Shoryuken::Client.sqs.create_queue(queue_name: ActiveJob::Base.queue_name_prefix + "_med_priority")
Shoryuken::Client.sqs.create_queue(queue_name: ActiveJob::Base.queue_name_prefix + "_high_priority")
end

Shoryuken.configure_server do |config|
Rails.logger = Shoryuken::Logging.logger
Rails.logger.level = Logger::INFO
Shoryuken.configure_server do |config|
Rails.logger = Shoryuken::Logging.logger
Rails.logger.level = Logger::INFO

# register all shoryuken middleware
config.server_middleware do |chain|
chain.add JobMetricsServiceMetricMiddleware
end
# register all shoryuken middleware
config.server_middleware do |chain|
chain.add JobMetricsServiceMetricMiddleware
end
end

0 comments on commit 8eda7c8

Please sign in to comment.