spec/inputs/rabbitmq_spec.rb in logstash-input-rabbitmq-3.1.2 vs spec/inputs/rabbitmq_spec.rb in logstash-input-rabbitmq-3.1.3
- old
+ new
@@ -66,12 +66,12 @@
expect(channel).to have_received(:prefetch=).with(123)
end
end
context "with an exchange declared" do
- let(:exchange) { double("exchange") }
- let(:key) { double("routing key") }
+ let(:exchange) { "exchange" }
+ let(:key) { "routing key" }
let(:rabbitmq_settings) { super.merge("exchange" => exchange, "key" => key) }
it "should bind to the exchange" do
instance.register
expect(queue).to have_received(:bind).with(exchange, :routing_key => key)
@@ -169,6 +169,6 @@
let(:config) { super.merge("queue" => "foo_queue") }
it_behaves_like "an interruptible input plugin" do
end
end
-end
\ No newline at end of file
+end