Class: Sidekiq::BasicFetch::UnitOfWork

Inherits:

Struct

• Object
• Struct
• Sidekiq::BasicFetch::UnitOfWork

Defined in:

lib/sidekiq/fetch.rb

Instance Attribute Summary

• #config ⇒ Object

  Returns the value of attribute config.

• #job ⇒ Object

  Returns the value of attribute job.

• #queue ⇒ Object

  Returns the value of attribute queue.

Instance Method Summary

• #acknowledge ⇒ Object
• #queue_name ⇒ Object
• #requeue ⇒ Object

Instance Attribute Details

#config ⇒ Object

Returns the value of attribute config

# File 'lib/sidekiq/fetch.rb', line 15

def config
  @config
end

#job ⇒ Object

Returns the value of attribute job

# File 'lib/sidekiq/fetch.rb', line 15

def job
  @job
end

#queue ⇒ Object

Returns the value of attribute queue

# File 'lib/sidekiq/fetch.rb', line 15

def queue
  @queue
end

Instance Method Details

#acknowledge ⇒ Object

# File 'lib/sidekiq/fetch.rb', line 16

def acknowledge
  # nothing to do
end

#queue_name ⇒ Object

# File 'lib/sidekiq/fetch.rb', line 20

def queue_name
  queue.delete_prefix("queue:")
end

#requeue ⇒ Object

# File 'lib/sidekiq/fetch.rb', line 24

def requeue
  config.redis do |conn|
    conn.rpush(queue, job)
  end
end