Class: Jiggler::AtLeastOnce::Fetcher::CurrentJob

Inherits:
Struct
  • Object
show all
Defined in:
lib/jiggler/at_least_once/fetcher.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#args ⇒ Object

Returns the value of attribute args

Returns:

  • (Object) —

    the current value of args



20
21
22
 
# File 'lib/jiggler/at_least_once/fetcher.rb', line 20

def args
  @args
end

#config ⇒ Object

Returns the value of attribute config

Returns:

  • (Object) —

    the current value of config



20
21
22
 
# File 'lib/jiggler/at_least_once/fetcher.rb', line 20

def config
  @config
end

#queue ⇒ Object

Returns the value of attribute queue

Returns:

  • (Object) —

    the current value of queue



20
21
22
 
# File 'lib/jiggler/at_least_once/fetcher.rb', line 20

def queue
  @queue
end

#reserve_queue ⇒ Object

Returns the value of attribute reserve_queue

Returns:

  • (Object) —

    the current value of reserve_queue



20
21
22
 
# File 'lib/jiggler/at_least_once/fetcher.rb', line 20

def reserve_queue
  @reserve_queue
end

Instance Method Details

#ack ⇒ Object 



21
22
23
24
25
 
# File 'lib/jiggler/at_least_once/fetcher.rb', line 21

def ack
  config.with_sync_redis do |conn|
    conn.call('LREM', reserve_queue, 1, args)
  end
end