README.md

@@ -399,23 +399,18 @@ SolidQueue.on_scheduler_stop
 For example:
 ```ruby
 SolidQueue.on_start do |supervisor|
-  Rails.logger.info "Supervisor #{supervisor.name} started"
+  MyMetricsReporter.process_name = supervisor.name
 
   start_metrics_server
 end
 
-SolidQueue.on_stop do |supervisor|
-  Rails.logger.info "Supervisor #{supervisor.name} stopped"
-
+SolidQueue.on_stop do |_supervisor|
   stop_metrics_server
 end
 
 SolidQueue.on_worker_start do |worker|
-  Rails.logger.info "Worker #{worker.name} started with queues: #{worker.queues.join(',')}"
-end
-
-SolidQueue.on_worker_stop do |worker|
-  Rails.logger.info "Worker #{worker.name} stopped with queues: #{worker.queues.join(',')}"
+  MyMetricsReporter.process_name = worker.name
+  MyMetricsReporter.queues = worker.queues.join(',')
 end
 ```
 

lib/solid_queue/scheduler.rb

@@ -5,6 +5,8 @@ class Scheduler < Processes::Base
     include Processes::Runnable
     include LifecycleHooks
 
+    attr_reader :recurring_schedule
+
     after_boot :run_start_hooks
     after_boot :schedule_recurring_tasks
     before_shutdown :unschedule_recurring_tasks
@@ -22,8 +24,6 @@ def metadata
     end
 
     private
-      attr_reader :recurring_schedule
-
       SLEEP_INTERVAL = 60 # Right now it doesn't matter, can be set to 1 in the future for dynamic tasks
 
       def run

lib/solid_queue/worker.rb

@@ -8,7 +8,7 @@ class Worker < Processes::Poller
     before_shutdown :run_stop_hooks
     after_shutdown :run_exit_hooks
 
-    attr_reader :queues
+    attr_reader :queues, :pool
 
     def initialize(**options)
       options = options.dup.with_defaults(SolidQueue::Configuration::WORKER_DEFAULTS)
@@ -26,8 +26,6 @@ def metadata
     end
 
     private
-      attr_reader :pool
-
       def poll
         claim_executions.then do |executions|
           executions.each do |execution|

test/unit/configuration_test.rb

@@ -135,8 +135,8 @@ def assert_processes(configuration, kind, count, **attributes)
     end
 
     def assert_has_recurring_task(scheduler, key:, **attributes)
-      assert_equal 1, scheduler.instance_variable_get(:@recurring_schedule).configured_tasks.count
-      task = scheduler.instance_variable_get(:@recurring_schedule).configured_tasks.detect { |t| t.key == key }
+      assert_equal 1, scheduler.recurring_schedule.configured_tasks.count
+      task = scheduler.recurring_schedule.configured_tasks.detect { |t| t.key == key }
 
       attributes.each do |attr, value|
         assert_equal_value value, task.public_send(attr)

test/unit/worker_test.rb

@@ -156,7 +156,7 @@ class WorkerTest < ActiveSupport::TestCase
     @worker.start
     wait_for_registered_processes(1, timeout: 1.second)
 
-    assert_not @worker.instance_variable_get(:@pool).shutdown?
+    assert_not @worker.pool.shutdown?
 
     process = SolidQueue::Process.first
     assert_equal "Worker", process.kind
@@ -165,8 +165,8 @@ class WorkerTest < ActiveSupport::TestCase
 
     # And now just wait until the worker tries to heartbeat and realises
     # it needs to stop
-    wait_while_with_timeout(2) { !@worker.instance_variable_get(:@pool).shutdown? }
-    assert @worker.instance_variable_get(:@pool).shutdown?
+    wait_while_with_timeout(2) { !@worker.pool.shutdown? }
+    assert @worker.pool.shutdown?
   ensure
     SolidQueue.process_heartbeat_interval = old_heartbeat_interval
   end