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