spec/waffle/event_spec.rb in waffle-0.4.0 vs spec/waffle/event_spec.rb in waffle-0.5.0

@@ -1,23 +1,26 @@
 require 'spec_helper'
 
 describe Waffle::Event do
   describe '.occured' do
-    let(:flow){'event'}
+    let(:flow){'event name'}
     let(:now){Time.now}
+    let(:options){{:event_name => flow, :queue => :default}}
+    let(:transport){double(:transport)}
     
     before do
       Time.stub(:now => now)
-      Waffle.should_receive(:publish).with(flow, message)
+      Waffle.should_receive(:queue).with(:default).and_return(transport)
+      transport.should_receive(:publish).with(flow, message)
     end
     
     context do
       let(:message){{"key1" => "value1", "key2" => "value2", "occured_at" => now}}
-      specify{Waffle::Event.occured(flow, {'key1' => 'value1', 'key2' => 'value2'})}
+      specify{Waffle::Event.occured(message, {:event_name => flow})}
     end
     
     context do
       let(:message){{"body" => "message data", "occured_at" => now}}
-      specify{Waffle::Event.occured(flow, 'message data')}
+      specify{Waffle::Event.occured('message data', {:event_name => flow})}
     end
   end
 end