Class: Totoro::BaseQueue

Inherits:

Object

• Object
• Totoro::BaseQueue

Defined in:

lib/totoro/base_queue.rb

Class Method Summary

• .broadcast(id, payload, attrs = {}) ⇒ Object
• .config ⇒ Object
• .connection ⇒ Object
• .enqueue(id, payload, attrs = {}) ⇒ Object

Class Method Details

.broadcast(id, payload, attrs = {}) ⇒ Object

# File 'lib/totoro/base_queue.rb', line 16

def broadcast(id, payload, attrs = {})
  Totoro::BroadcastService.new(connection, config).broadcast(id, payload, attrs)
rescue Totoro::ConnectionBreakError => error
  handle_failed_msg(id, payload, error, :broadcast)
end

.config ⇒ Object

# File 'lib/totoro/base_queue.rb', line 8

def config
  @config ||= Totoro::Config.new
end

.connection ⇒ Object

# File 'lib/totoro/base_queue.rb', line 12

def connection
  @connection ||= Bunny.new(config.connect.merge(threaded: false))
end

.enqueue(id, payload, attrs = {}) ⇒ Object

# File 'lib/totoro/base_queue.rb', line 22

def enqueue(id, payload, attrs = {})
  Totoro::EnqueueService.new(connection, config).enqueue(id, payload, attrs)
rescue Totoro::ConnectionBreakError => error
  handle_failed_msg(id, payload, error, :enqueue)
end