Contents

# encoding: utf-8
def push_sqs_event(message)
  client = Aws::SQS::Client.new
  queue_url = client.get_queue_url(:queue_name => ENV["SQS_QUEUE_NAME"])

  client.send_message({
    queue_url: queue_url.queue_url,
    message_body: message,
  })
end

Version data entries

21 entries across 21 versions & 1 rubygems

Version	Path
logstash-input-sqs-1.1.0	spec/support/helpers.rb