Class: IntellisenseRuby::SQS_Publisher

Inherits:
Object
  • Object
show all
Defined in:
lib/intellisense-ruby/sqs_publisher.rb

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ SQS_Publisher

Returns a new instance of SQS_Publisher.



10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
 
# File 'lib/intellisense-ruby/sqs_publisher.rb', line 10

def initialize(options = {})

  @sqs = AWS::SQS.new(
    :access_key_id => options[:warehouse_access_key_id],
    :secret_access_key => options[:warehouse_secret_access_key])

  @sqs_queue = @sqs.queues[options[:warehouse_queue_url]]

  @logger = options[:logger]
  log('DEBUG ############## SQS_Publisher created! with queue ' + @sqs_queue.to_s)

  #queue_urls = @sqs.queues.collect(&:url)
  #queue = @sqs.queues[queue_urls[0]]
  #pp queue
  # msg = queue.send_message("TEST")
  # puts "Sent message: #{msg.id}"

end

Instance Method Details

#send_message(message = {}) ⇒ Object 



29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/intellisense-ruby/sqs_publisher.rb', line 29

def send_message(message = {})

	return false unless @sqs_queue

  log('DEBUG ############## SQS_Publisher created! sending message ' + message.to_s)

	val = message.to_s
	msg = @sqs_queue.send_message(val)
	puts "Sent message: #{msg.id}"

end