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