Class: Barbeque::MessageEnqueuingService

Inherits:
Object
  • Object
show all
Defined in:
app/services/barbeque/message_enqueuing_service.rb

Constant Summary collapse

DEFAULT_QUEUE = 
ENV['BARBEQUE_DEFAULT_QUEUE'] || 'default'

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(application:, job:, message:, queue: nil) ⇒ MessageEnqueuingService

Returns a new instance of MessageEnqueuingService.

Parameters:

  • application (String)
  • job (String)
  • message (Object)
  • queue (String) (defaults to: nil) 


14
15
16
17
18
19
 
# File 'app/services/barbeque/message_enqueuing_service.rb', line 14

def initialize(application:, job:, message:, queue: nil)
  @application = application
  @job         = job
  @queue       = queue || DEFAULT_QUEUE
  @message     = message
end

Class Method Details

.sqs_client ⇒ Object 



6
7
8
 
# File 'app/services/barbeque/message_enqueuing_service.rb', line 6

def self.sqs_client
  @sqs_client ||= Aws::SQS::Client.new
end

Instance Method Details

#run ⇒ String

Returns message_id.

Returns:

  • (String) —

    message_id



22
23
24
25
26
27
28
29
 
# File 'app/services/barbeque/message_enqueuing_service.rb', line 22

def run
  queue_url = Barbeque::JobQueue.queue_url_from_name(@queue)
  response = Barbeque::MessageEnqueuingService.sqs_client.send_message(
    queue_url:    queue_url,
    message_body: build_message.to_json,
  )
  response.message_id
end