spec/lib/dispatch-rider/publisher_spec.rb in dispatch-rider-2.0.0 vs spec/lib/dispatch-rider/publisher_spec.rb in dispatch-rider-2.1.0
- old
+ new
@@ -133,28 +133,19 @@
end
describe "calls publish callback" do
describe "calls the publish callback" do
let(:publish_callback) { double :callback }
- let(:expected_message) {
- DispatchRider::Message.new(
- subject: "bar_handler",
- body: {
- "bar" => "baz",
- guid: "test-mode-not-random-guid"
- }
- )
- }
before { DispatchRider.config.callbacks.for(:publish) << publish_callback }
after { DispatchRider.config.callbacks.for(:publish).delete publish_callback }
example do
- expect(publish_callback).to receive(:call).with any_args, # first argument is the inner job
- destinations: [:fs_foo],
- message: expected_message
-
+ expect(publish_callback).to receive(:call).with(
+ an_instance_of(Proc), # first argument is the inner job
+ { destinations: [:fs_foo],
+ message: an_instance_of(DispatchRider::Message) })
publisher.publish destinations: [:fs_foo],
message: {
subject: "bar_handler",
body: { "bar" => "baz" }
}