lib/client.rb views/queue_created.haml @@ -5,7 +5,7 @@ SQS Accelerator _WARNING: this is totally experimental right now! It's just an idea I'm playing with and I'm trying to see if it works. (But please try it out and tell me what you think!)_ -This is a simple evented server (using [Event Machine](http://eventmachine.rubyforge.org)) that proxies requests to Amazon's [Simple Queue Service](http://aws.amazon.com/sqs/) hosted queue. It's purpose is to queue messages very quickly, because otherwise SQS is too slow to use from within a web app (to be precise, the time it takes to queue a message is often too long). +This is a simple and scalable event-driven server (using [Event Machine](http://eventmachine.rubyforge.org)) that proxies requests to Amazon's [Simple Queue Service](http://aws.amazon.com/sqs/) hosted queue. It's purpose is to queue messages very quickly, because otherwise SQS is too slow to use from within a web app (to be precise, the time it takes to queue a message is often too long). It provides a simple RESTful interface for interacting with SQS that's also convenient to use from a browser. README.markdown @@ -1,8 +1,14 @@ require "em-http" -require "sqs_helper" -require "sqs_proxy" +require "haml" +require "logger" +require "pp" +require "sinatra/async" require "xml" +require "#{File.dirname(__FILE__)}/sqs_accelerator" +require "#{File.dirname(__FILE__)}/sqs_helper" +require "#{File.dirname(__FILE__)}/sqs_proxy" + class SqsAccelerator::Server < Sinatra::Base register Sinatra::Async @@ -81,7 +87,10 @@ class SqsAccelerator::Server < Sinatra::Base operation = proc do sqs = SqsAccelerator::SqsProxy.new(aws_access_key_id, aws_secret_access_key, :logger => logger) sqs.create_queue(queue_name, visibility_timeout) - redirect "/queues/#{queue_name}" + # TODO check the result and return an error unless success + # TODO set Location header field with URI + response.status = 201 # "Created": http://www.w3.org/Protocols/rfc2616/rfc2616-sec10.html + body haml :queue_created, :locals => { :queue_name => queue_name } end EM.defer(operation) end @@ -121,7 +130,9 @@ class SqsAccelerator::Server < Sinatra::Base end # Messaage seems to be OK, return a response immediately then send message to SQS + response.status = 202 # "Accepted": http://www.w3.org/Protocols/rfc2616/rfc2616-sec10.html body "Message will be queued, check log for errors.\n" + # TODO generate and return a message id then log that with the SQS message id? request_hash = generate_request_hash("SendMessage", :message => message_body) # build the body string ourselves for now until Ilya's gem gets updated because of the content-length bug lib/server.rb @@ -1,12 +1,2 @@ -require "sinatra/async" -require "logger" -require "haml" -require "pp" - module SqsAccelerator end - -# Dir.glob(File.dirname(__FILE__) + "/*.rb").each do |file| -# require file -# end -require "lib/server" \ No newline at end of file lib/sqs_accelerator.rb @@ -3,7 +3,7 @@ spec = Gem::Specification.new do |s| s.version = '0.0.1' s.date = '2009-06-22' s.summary = 'SQS Accelerator' - s.description = "A simple evented server that proxies requests to Amazon's Simple Queue Service to queue messages very quickly." + s.description = "A simple and scalable event-drive server that proxies requests to Amazon's Simple Queue Service to queue messages very quickly." s.email = 'paul@pauldowman.com' s.homepage = "http://github.com/pauldowman/sqs-accelerator" s.has_rdoc = false sqs_accelerator.gemspec @@ -1,5 +1,5 @@ #!/usr/bin/env rackup -Ilib:../lib -s thin -require 'lib/sqs_accelerator' +require 'lib/server' run SqsAccelerator::Server.new sqs_accelerator.ru e6fd8ce1f63659ba6abc0bfc0e8bc5f7d97fbf81 Paul Dowman paul@pauldowman.com http://github.com/pauldowman/sqs_accelerator/commit/37a52ff98af5d4b51e136be4d8f34982c1529e1b 37a52ff98af5d4b51e136be4d8f34982c1529e1b 2009-06-23T13:21:59-07:00 2009-06-23T12:42:45-07:00 Added simple ruby client class and server actions now return more precise HTTP response codes 34b2c5160307605bfddcad651bc1bb645b57c6a0 Paul Dowman paul@pauldowman.com