spec/archiver_spec.rb in alephant-publisher-queue-2.0.2 vs spec/archiver_spec.rb in alephant-publisher-queue-2.0.3
- old
+ new
@@ -1,16 +1,18 @@
require "spec_helper"
describe Alephant::Publisher::Queue::SQSHelper::Archiver do
- let (:cache) { instance_double("Alephant::Cache", :put => nil) }
- let (:queue) { instance_double("AWS::SQS::Queue", :url => nil) }
+ let (:cache) { instance_double("Alephant::Cache", :put => nil) }
+ let (:queue) { instance_double("AWS::SQS::Queue", :url => nil) }
+ let (:msg_body) {{ :Message => JSON.generate(msg_uri) }}
+ let (:msg_uri) {{ :uri => "/content/asset/newsbeat" }}
let (:message) do
instance_double(
"AWS::SQS::ReceivedMessage",
:id => "id",
- :body => "bar_baz",
:md5 => "qux",
- :queue => queue
+ :queue => queue,
+ :body => JSON.generate(msg_body)
)
end
let (:opts) do
{