Class: ChiliLogger::AWS::SqsBroker

Inherits:
Object
  • Object
show all
Defined in:
lib/brokers/sqs_broker.rb

Overview

class that handles errors when message broker can’t be reached, etc…

Instance Method Summary collapse

Constructor Details

#initialize(config) ⇒ SqsBroker

Returns a new instance of SqsBroker.



9
10
11
12
13
14
15
 
# File 'lib/brokers/sqs_broker.rb', line 9

def initialize(config)
  @sqs_config = validate_config(config)
  @queue_name = config[:queue_name]
  @default = ChiliLogger::Values::Default.new

  @sqs = Aws::SQS::Client.new(@sqs_config)
end

Instance Method Details

#publish(message = @default.sqs_message) ⇒ Object 



17
18
19
20
21
22
 
# File 'lib/brokers/sqs_broker.rb', line 17

def publish(message = @default.sqs_message)
  message_body = { body: message }
  queue_message = queue_message(message_body)

  @sqs.send_message(queue_message)
end