class QueueingRabbit::AbstractJob

Attributes

metadata[R]
payload[R]

Public Class Methods

new(payload, metadata) click to toggle source
# File lib/queueing_rabbit/jobs/abstract_job.rb, line 9
def initialize(payload, metadata)
  @payload = payload
  @metadata = metadata
end

Public Instance Methods

acknowledge() click to toggle source
# File lib/queueing_rabbit/jobs/abstract_job.rb, line 14
def acknowledge
  metadata.ack
end
headers() click to toggle source
# File lib/queueing_rabbit/jobs/abstract_job.rb, line 18
def headers
  metadata.headers || {}
end
perform() click to toggle source
# File lib/queueing_rabbit/jobs/abstract_job.rb, line 22
def perform
end