class RubyEventStore::Outbox::CleanupStrategies::CleanOldEnqueued
Attributes
duration[R]
repository[R]
Public Class Methods
new(repository, duration)
click to toggle source
# File lib/ruby_event_store/outbox/cleanup_strategies/clean_old_enqueued.rb, line 5 def initialize(repository, duration) @repository = repository @duration = duration end
Public Instance Methods
call(fetch_specification)
click to toggle source
# File lib/ruby_event_store/outbox/cleanup_strategies/clean_old_enqueued.rb, line 10 def call(fetch_specification) repository.delete_enqueued_older_than(fetch_specification, duration) end