Method: Chore::Queues::SQS::Publisher#publish

Defined in:
lib/chore/queues/sqs/publisher.rb

#publish(queue_name, job) ⇒ struct Aws::SQS::Types::SendMessageResult

Publishes a message to an SQS queue

Parameters:

  • queue_name (String) —

    Name of the SQS queue

  • job (Hash) —

    Job instance definition, will be encoded to JSON

Returns:

  • (struct Aws::SQS::Types::SendMessageResult) 


23
24
25
26
 
# File 'lib/chore/queues/sqs/publisher.rb', line 23

def publish(queue_name,job)
  queue = queue(queue_name)
  queue.send_message(message_body: encode_job(job))
end