returns existing queue if exist

iain · Jun 17, 2015 · 785129f · 785129f
1 parent e7fea69
commit 785129f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 11 deletions.
diff --git a/lib/fake_sqs/queues.rb b/lib/fake_sqs/queues.rb
@@ -14,12 +14,9 @@ def initialize(options = {})
     end
 
     def create(name, options = {})
-      if database[name]
-        fail QueueNameExists, name
-      else
-        queue = queue_factory.new(options)
-        database[name] = queue
-      end
+      return database[name] if database[name]
+      queue = queue_factory.new(options)
+      database[name] = queue
     end
 
     def delete(name, options = {})

diff --git a/spec/unit/queues_spec.rb b/spec/unit/queues_spec.rb
@@ -27,11 +27,9 @@
       expect(create_queue("test")).to eq queue
     end
 
-    it "cannot create a queue with the same name" do
-      create_queue("test")
-      expect {
-        create_queue("test")
-      }.to raise_error(FakeSQS::QueueNameExists, "test")
+    it "returns existing queue if the queue exists" do
+      queue = create_queue("test")
+      expect(create_queue("test")).to eq(queue)
     end
 
   end