@@ -8,6 +8,7 @@ require 'date' require 'open-uri' require 'xmlsimple' require 'mime/types' +require 'builder' $:.unshift(File.dirname(__FILE__)) lib/azuli.rb @@ -47,6 +47,13 @@ module Azuli set_request_content(request, content) connection.do_request(request, [Net::HTTPConflict]) end + def post(path, content=nil, qstring={}) + connection = new_connection + request = Azuli::Post.new(connection.make_path(path)) + set_request_content(request, content) + request.add_qstring_params qstring + connection.do_request request + end def put_metadata(path, properties) connection = new_connection request = Azuli::Put.new(connection.make_path(path), properties) lib/azuli/base.rb @@ -72,6 +72,11 @@ module Azuli REQUEST_HAS_BODY = true RESPONSE_HAS_BODY = true end + class Post < AzureRequest + METHOD = 'POST' + REQUEST_HAS_BODY = true + RESPONSE_HAS_BODY = true + end class Get < AzureRequest METHOD = 'GET' REQUEST_HAS_BODY = false lib/azuli/connection.rb @@ -4,6 +4,18 @@ module Azuli def create(name, metadata = {}) put(name, Metadata.to_meta(metadata)) end + def push(queue_name, message_text, options={}) + xml = Builder::XmlMarkup.new + msg = xml.QueueMessage { + xml.MessageText(message_text) + } + post(messages_path(queue_name), msg, options) + end + + private + def messages_path(queue_name) + "/#{queue_name}/messages" + end end end end lib/azuli/queue.rb @@ -7,4 +7,14 @@ class TestQueue < Test::Unit::TestCase def test_can_create assert_nothing_raised { Queue.create new_object_name } end + def test_can_push + name = new_object_name + Queue.create name + assert_nothing_raised { Queue.push name, "This is the message text" } + end + def test_can_push_with_ttl + name = new_object_name + Queue.create name + assert_nothing_raised { Queue.push name, "This is the message text", { :messagettl => 5 } } + end end tests/units/queue.rb 936643c17f30e830d80fadad6581d4cd3c09bc27 Tomas Restrepo tomas@winterdom.com http://github.com/tomasr/azuli/commit/93f56dc77a4ad557e0426e3d7833ecaa3e713fb5 93f56dc77a4ad557e0426e3d7833ecaa3e713fb5 2008-10-29T11:06:52-07:00 2008-10-29T11:06:52-07:00 Added Queue.push 2d1826b0a6d070d1ec5e4e22b81fcfe8fe3e2c34 Tomas Restrepo tomas@winterdom.com