```ruby class EventCreatedJob include Sidekiq::Job def self.perform_async(event_id, event_type) can_handle?(event_type: event_type) ? super : nil end def perform(event_id, event_type) end end ``` ```ruby module OutboxerIntegration class TestStartedJob include Sidekiq::Job def perform(event_id, event_type) test_started_event = event_type.safe_constantize.find(event_id) TestCompletedEvent.create!(body: { "test_id" => test_started_event.body["test_id"] }) end end end ```