Class: Roundhouse::RoundRobinFetch::UnitOfWork

Inherits:
Struct
  • Object
show all
Defined in:
lib/roundhouse/fetch.rb

Constant Summary collapse

QUEUE_REGEX = 
/.*#{Roundhouse::Monitor::QUEUE}:/.freeze

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#full_queue_name ⇒ Object

Returns the value of attribute full_queue_name

Returns:

  • (Object) —

    the current value of full_queue_name



134
135
136
 
# File 'lib/roundhouse/fetch.rb', line 134

def full_queue_name
  @full_queue_name
end

#message ⇒ Object

Returns the value of attribute message

Returns:

  • (Object) —

    the current value of message



134
135
136
 
# File 'lib/roundhouse/fetch.rb', line 134

def message
  @message
end

Instance Method Details

#acknowledge ⇒ Object 



137
138
139
 
# File 'lib/roundhouse/fetch.rb', line 137

def acknowledge
  # nothing to do
end

#queue_id ⇒ Object 



141
142
143
 
# File 'lib/roundhouse/fetch.rb', line 141

def queue_id
  full_queue_name.gsub(QUEUE_REGEX, '')
end

#requeue ⇒ Object 



145
146
147
148
149
150
 
# File 'lib/roundhouse/fetch.rb', line 145

def requeue
  Roundhouse.redis do |conn|
    Roundhouse::Monitor.requeue(conn, queue_id, message)
    Roundhouse::Monitor.push(conn, queue_id)
  end
end