spec/alephant/publisher/queue/processor_spec.rb in alephant-publisher-queue-2.5.0 vs spec/alephant/publisher/queue/processor_spec.rb in alephant-publisher-queue-2.6.0

@@ -9,13 +9,14 @@
     allow_any_instance_of(
       Alephant::Publisher::Queue::Writer
     ).to receive(:run!)
   end
 
-  describe "#consume(msg)" do
+  describe "#consume" do
     it "Consume the message and deletes it" do
-      msg = instance_double(AWS::SQS::ReceivedMessage, :delete => nil)
-      expect(msg).to receive(:delete)
-      subject.consume(msg)
+      message = instance_double(Aws::SQS::Message, :delete => nil)
+      message_collection = [message]
+      expect(message).to receive(:delete)
+      subject.consume(message_collection)
     end
   end
 end