Sha256: 6f5fbd9ff9982c685db08042f54c9082244bc9dadab5cde9d7cc52388898d37b

Contents?: true

Size: 248 Bytes

Versions: 21

Compression:

Stored size: 248 Bytes

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-3.3.2 spec/support/helpers.rb
logstash-input-sqs-3.3.1 spec/support/helpers.rb
logstash-input-sqs-3.3.0 spec/support/helpers.rb
logstash-input-sqs-3.2.0 spec/support/helpers.rb
logstash-input-sqs-3.1.3 spec/support/helpers.rb
logstash-input-sqs-3.1.2 spec/support/helpers.rb
logstash-input-sqs-3.1.1 spec/support/helpers.rb
logstash-input-sqs-3.1.0 spec/support/helpers.rb
logstash-input-sqs-3.0.6 spec/support/helpers.rb
logstash-input-sqs-3.0.5 spec/support/helpers.rb
logstash-input-sqs-3.0.4 spec/support/helpers.rb
logstash-input-sqs-3.0.3 spec/support/helpers.rb
logstash-input-sqs-3.0.2 spec/support/helpers.rb
logstash-input-sqs-3.0.1 spec/support/helpers.rb
logstash-input-sqs-3.0.0 spec/support/helpers.rb
logstash-input-sqs-2.0.5 spec/support/helpers.rb
logstash-input-sqs-2.0.3 spec/support/helpers.rb
logstash-input-sqs-2.0.2 spec/support/helpers.rb
logstash-input-sqs-2.0.1 spec/support/helpers.rb
logstash-input-sqs-2.0.0 spec/support/helpers.rb