Class: MinimalPipeline::Sqs
- Inherits:
-
Object
- Object
- MinimalPipeline::Sqs
- Defined in:
- lib/minimal_pipeline/sqs.rb
Overview
Here is an example of how to use this class to send a message onto a queue.
“‘ sqs = MinimalPipeline::Sqs.new message = ’Beep boop’ sqs.send_message(‘queue-name’, message) “‘
Instance Method Summary collapse
-
#initialize ⇒ Sqs
constructor
A new instance of Sqs.
-
#send_message(queue_name, body) ⇒ Aws::SQS::Types::SendMessageResult
Places a message on a SQS queue.
Constructor Details
#initialize ⇒ Sqs
Returns a new instance of Sqs.
12 13 14 15 16 17 18 |
# File 'lib/minimal_pipeline/sqs.rb', line 12 def initialize raise 'You must set env variable AWS_REGION or region.' \ if ENV['AWS_REGION'].nil? && ENV['region'].nil? region = ENV['AWS_REGION'] || ENV['region'] @client = Aws::SQS::Client.new(region: region) end |
Instance Method Details
#send_message(queue_name, body) ⇒ Aws::SQS::Types::SendMessageResult
Places a message on a SQS queue
25 26 27 28 29 |
# File 'lib/minimal_pipeline/sqs.rb', line 25 def (queue_name, body) queue_url = @client.get_queue_url(queue_name: queue_name).queue_url @client.(queue_url: queue_url, message_body: body, message_group_id: queue_name) end |