lib/alephant/harness/service/sqs.rb in alephant-harness-0.1.1 vs lib/alephant/harness/service/sqs.rb in alephant-harness-0.1.2

@@ -8,15 +8,15 @@
         def self.client
           @@client ||= ::AWS::SQS.new
         end
 
         def self.create(queue)
-          client.queues.create /(?<name>[^\/]+)$/.match(queue)[:name]
+          client.queues.create queue_name(queue)
         end
 
-        def self.get(queue_name)
-          client.queues.named(queue_name)
+        def self.get(queue)
+          client.queues.named(queue_name(queue))
         rescue ::AWS::SQS::Errors::NonExistentQueue
           false
         end
 
         def self.exists?(queue_name)
@@ -24,10 +24,14 @@
             yield
           end
         end
 
         def self.delete(queue_name)
-          client.queues.named(queue_name).delete
+          get(queue_name).delete
+        end
+
+        def self.queue_name(queue)
+          /(?<name>[^\/]+)$/.match(queue)[:name]
         end
 
       end
     end
   end