lib/waffle/event.rb in waffle-0.4.0 vs lib/waffle/event.rb in waffle-0.5.0

@@ -1,15 +1,20 @@
 module Waffle
   class Event
     class << self
-      def occured(event_name = 'event', event_data = nil)
+      def occured(event_data, options = {})
+        options = {
+          :event_name => 'event',
+          :queue => :default
+        }.merge(options)
+
         unless event_data.is_a?(Hash)
           event_data = {'body' => event_data.to_s}
         end
 
         event_data.merge!({'occured_at' => Time.now})
 
-        Waffle.publish(event_name, event_data)
+        Waffle.queue(options[:queue]).publish(options[:event_name], event_data)
       end
       alias :occurred :occured
     end
   end
 end