Class: RubyEventStore::Outbox::CleanupStrategies::CleanOldEnqueued

Inherits:

Object

Object
RubyEventStore::Outbox::CleanupStrategies::CleanOldEnqueued

show all

Defined in:: lib/ruby_event_store/outbox/cleanup_strategies/clean_old_enqueued.rb

Instance Method Summary collapse

#call(fetch_specification) ⇒ Object
#initialize(repository, duration, limit) ⇒ CleanOldEnqueued constructor

A new instance of CleanOldEnqueued.

Constructor Details

#initialize(repository, duration, limit) ⇒ `CleanOldEnqueued`

Returns a new instance of CleanOldEnqueued.

# File 'lib/ruby_event_store/outbox/cleanup_strategies/clean_old_enqueued.rb', line 7

def initialize(repository, duration, limit)
  @repository = repository
  @duration = duration
  @limit = limit
end

Instance Method Details

#call(fetch_specification) ⇒ `Object`



13
14
15

# File 'lib/ruby_event_store/outbox/cleanup_strategies/clean_old_enqueued.rb', line 13

def call(fetch_specification)
  repository.delete_enqueued_older_than(fetch_specification, duration, limit)
end