class RubyEventStore::Outbox::SidekiqScheduler
Attributes
sidekiq_producer[R]
Public Class Methods
new()
click to toggle source
# File lib/ruby_event_store/outbox/sidekiq_scheduler.rb, line 8 def initialize @sidekiq_producer = SidekiqProducer.new end
Public Instance Methods
call(klass, serialized_record)
click to toggle source
# File lib/ruby_event_store/outbox/sidekiq_scheduler.rb, line 12 def call(klass, serialized_record) sidekiq_producer.call(klass, [serialized_record.to_h]) end
verify(subscriber)
click to toggle source
# File lib/ruby_event_store/outbox/sidekiq_scheduler.rb, line 16 def verify(subscriber) Class === subscriber && subscriber.respond_to?(:through_outbox?) && subscriber.through_outbox? end