Skip to content

Commit

Permalink
Added sqs worker example.
Browse files Browse the repository at this point in the history
  • Loading branch information
dbalatero committed Jun 9, 2009
1 parent 3563a18 commit 097d080
Show file tree
Hide file tree
Showing 3 changed files with 42 additions and 0 deletions.
17 changes: 17 additions & 0 deletions examples/sqs_worker/simple_sqs_producer.rb
Original file line number Diff line number Diff line change
@@ -0,0 +1,17 @@
#!/usr/bin/env ruby

require 'right_aws'

sqs = RightAws::SqsGen2.new('<your access key>',
'<your secret key>',
:multi_thread => false,
:signature_version => '1')
queue = sqs.queue('my_test_queue', true)

i = 1
while true
print "[#{i}] Enter a message to put to SQS: "
message = gets
queue.push(message)
i += 1
end
6 changes: 6 additions & 0 deletions examples/sqs_worker/simple_sqs_runner.rb
Original file line number Diff line number Diff line change
@@ -0,0 +1,6 @@
#!/usr/bin/env ruby

require File.dirname(__FILE__) + '/simple_sqs_worker'

runner = QueueStick::Runner.new(ARGV)
runner.run!(SimpleSQSWorker)
19 changes: 19 additions & 0 deletions examples/sqs_worker/simple_sqs_worker.rb
Original file line number Diff line number Diff line change
@@ -0,0 +1,19 @@
require File.dirname(__FILE__) + '/../../lib/queue_stick'

class SimpleSQSWorker < QueueStick::SQSWorker
aws_access_key_id '<your key here>'
aws_secret_access_key '<your secret here>'
queue_name 'my_test_queue'
visibility_timeout 120

# This worker just prints out the message from the SQS
# queue.
def process(message)
puts "Got message from SQS: " << message
sleep 2
end

def recover
puts "whoops, there was an error. oh well!"
end
end

0 comments on commit 097d080

Please sign in to comment.