Class: RubyEventStore::Outbox::SidekiqScheduler

Inherits:
Object
  • Object
show all
Defined in:
lib/ruby_event_store/outbox/sidekiq_scheduler.rb

Instance Method Summary collapse

Constructor Details

#initialize(serializer: Serializers::YAML) ⇒ SidekiqScheduler

Returns a new instance of SidekiqScheduler.



8
9
10
11
 
# File 'lib/ruby_event_store/outbox/sidekiq_scheduler.rb', line 8

def initialize(serializer: Serializers::YAML)
  @serializer = serializer
  @sidekiq_producer = SidekiqProducer.new
end

Instance Method Details

#call(klass, record) ⇒ Object 



13
14
15
 
# File 'lib/ruby_event_store/outbox/sidekiq_scheduler.rb', line 13

def call(klass, record)
  sidekiq_producer.call(klass, [record.serialize(serializer)])
end

#verify(subscriber) ⇒ Object 



17
18
19
 
# File 'lib/ruby_event_store/outbox/sidekiq_scheduler.rb', line 17

def verify(subscriber)
  Class === subscriber && subscriber.respond_to?(:through_outbox?) && subscriber.through_outbox?
end