[rackspace|queues] adding more examples

lib/fog/rackspace/examples/queues/claim_messages.rb

@@ -0,0 +1,60 @@
+#!/usr/bin/env ruby
+
+# This example demonstrates claiming messages with the Rackpace Open Cloud
+
+require 'rubygems' #required for Ruby 1.8.x
+require 'fog'
+
+def get_user_input(prompt)
+  print "#{prompt}: "
+  gets.chomp
+end
+
+def select_queue(queues)
+  abort "\nThere are not any queues the Chicago region. Try running create_queue.rb\n\n" if queues.empty?
+
+  puts "\nSelect Queue To Delete:\n\n"
+  queues.each_with_index do |queue, i|
+    puts "\t #{i}. #{queue.name}"
+  end
+
+  delete_str = get_user_input "\nEnter Queue Number"
+  queues[delete_str.to_i]
+end
+
+# Use username defined in ~/.fog file, if absent prompt for username.
+# For more details on ~/.fog refer to http://fog.io/about/getting_started.html
+def rackspace_username
+  Fog.credentials[:rackspace_username] || get_user_input("Enter Rackspace Username")
+end
+
+# Use api key defined in ~/.fog file, if absent prompt for api key
+# For more details on ~/.fog refer to http://fog.io/about/getting_started.html
+def rackspace_api_key
+  Fog.credentials[:rackspace_api_key] || get_user_input("Enter Rackspace API key")
+end
+
+# create Queue Service
+service = Fog::Rackspace::Queues.new({
+  # :rackspace_username   => rackspace_username,
+  # :rackspace_api_key    => rackspace_api_key,
+  :rackspace_region => :ord #Use Chicago Region
+})
+
+# retrieve list of queues
+queues = service.queues
+
+# prompt for queue
+queue = select_queue(queues)
+
+# prompt for number of messages to claim
+num_claims = get_user_input "Enter Number of Messages to Claim"
+
+# Claim messages
+claim = queue.claims.create :ttl => 300, :grace => 100, :limit => num_claims
+
+puts "The following messages have been claimed for the next 5 minutes [#{claim.id}]"
+
+claim.messages.each do |message|
+  puts "\t[#{message.id}] #{message.body[0..50]}"
+end

lib/fog/rackspace/examples/queues/delete_message.rb

@@ -0,0 +1,72 @@
+#!/usr/bin/env ruby
+
+# This example demonstrates deleting a message with the Rackpace Open Cloud
+
+require 'rubygems' #required for Ruby 1.8.x
+require 'fog'
+
+def get_user_input(prompt)
+  print "#{prompt}: "
+  gets.chomp
+end
+
+def select_queue(queues)
+  abort "\nThere are not any queues in the Chicago region. Try running create_queue.rb\n\n" if queues.empty?
+
+  puts "\nSelect Queue To Delete:\n\n"
+  queues.each_with_index do |queue, i|
+    puts "\t #{i}. #{queue.name}"
+  end
+
+  delete_str = get_user_input "\nEnter Queue Number"
+  queues[delete_str.to_i]
+end
+
+def select_message(messages)
+  abort "\nThere are not any messages in the Chicago region. Try running post_message.rb\n\n" if messages.empty?
+
+  puts "\nSelect Message To Delete:\n\n"
+  messages.each_with_index do |message, i|
+    puts "\t #{i}. [#{message.id}] #{message.body[0..50]}"
+  end
+
+  delete_str = get_user_input "\nEnter Message Number"
+  messages[delete_str.to_i]
+end
+
+
+# Use username defined in ~/.fog file, if absent prompt for username.
+# For more details on ~/.fog refer to http://fog.io/about/getting_started.html
+def rackspace_username
+  Fog.credentials[:rackspace_username] || get_user_input("Enter Rackspace Username")
+end
+
+# Use api key defined in ~/.fog file, if absent prompt for api key
+# For more details on ~/.fog refer to http://fog.io/about/getting_started.html
+def rackspace_api_key
+  Fog.credentials[:rackspace_api_key] || get_user_input("Enter Rackspace API key")
+end
+
+# create Queue Service
+service = Fog::Rackspace::Queues.new({
+  :rackspace_username   => rackspace_username,
+  :rackspace_api_key    => rackspace_api_key,
+  :rackspace_region => :ord #Use Chicago Region
+})
+
+# retrieve list of queues
+queues = service.queues
+
+# prompt for queue
+queue = select_queue(queues)
+
+#retrieve list of messages
+messages = queue.messages
+
+# prompt for message
+message = select_message(messages)
+
+# delete message
+message.destroy
+
+puts "\nMessage #{message.id} has been destroyed\n"

lib/fog/rackspace/examples/queues/list_messages.rb

@@ -0,0 +1,64 @@
+#!/usr/bin/env ruby
+
+# This example demonstrates listing messages in a queue with the Rackpace Open Cloud
+
+require 'rubygems' #required for Ruby 1.8.x
+require 'fog'
+
+def get_user_input(prompt)
+  print "#{prompt}: "
+  gets.chomp
+end
+
+def get_user_boolean(prompt)
+  str = get_user_input(prompt)
+  return false unless str
+  str.match(/y(es)?/i) ? true : false
+end
+
+def select_queue(queues)
+  abort "\nThere are not any queues to post a message to in the Chicago region. Try running create_queue.rb\n\n" if queues.empty?
+
+  puts "\nSelect Queue:\n\n"
+  queues.each_with_index do |queue, i|
+    puts "\t #{i}. #{queue.name}"
+  end
+
+  delete_str = get_user_input "\nEnter Queue Number"
+  queues[delete_str.to_i]
+end
+
+# Use username defined in ~/.fog file, if absent prompt for username.
+# For more details on ~/.fog refer to http://fog.io/about/getting_started.html
+def rackspace_username
+  Fog.credentials[:rackspace_username] || get_user_input("Enter Rackspace Username")
+end
+
+# Use api key defined in ~/.fog file, if absent prompt for api key
+# For more details on ~/.fog refer to http://fog.io/about/getting_started.html
+def rackspace_api_key
+  Fog.credentials[:rackspace_api_key] || get_user_input("Enter Rackspace API key")
+end
+
+# create Queue Service
+service = Fog::Rackspace::Queues.new({
+  # :rackspace_username   => rackspace_username,
+  # :rackspace_api_key    => rackspace_api_key,
+  :rackspace_region => :ord #Use Chicago Region
+})
+
+# retrieve list of queues
+queues = service.queues
+
+# prompt for queue to delete
+queue = select_queue(queues)
+
+queue.messages.echo = get_user_boolean "Do you want to include your own messages? [y/N]"
+
+queue.messages.include_claimed = get_user_boolean "Do you want to include claimed messages? [y/N]"
+
+puts "\n\nThe following messages are in the '#{queue.name}' queue:\n\n"
+
+queue.messages.each do |message|
+  puts message.inspect
+end

lib/fog/rackspace/examples/queues/post_message.rb

@@ -1,6 +1,6 @@
 #!/usr/bin/env ruby
 
-# This example demonstrates deleting a queue with the Rackpace Open Cloud
+# This example demonstrates posting a message to a queue with the Rackpace Open Cloud
 
 require 'rubygems' #required for Ruby 1.8.x
 require 'fog'
@@ -13,7 +13,7 @@ end
 def select_queue(queues)
   abort "\nThere are not any queues to post a message to in the Chicago region. Try running create_queue.rb\n\n" if queues.empty?
 
-  puts "\nSelect Queue To Delete:\n\n"
+  puts "\nSelect Queue:\n\n"
   queues.each_with_index do |queue, i|
     puts "\t #{i}. #{queue.name}"
   end