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

- old
+ new

@@ -1,34 +1,16 @@ -require 'singleton' - module Waffle class Event - include Singleton - class << self - # Syntactic sugar ^_^ - def occured(*args) - self.instance.occured(*args) - end - alias :occurred :occured - end + def occured(event_name = 'event', event_data = nil) + unless event_data.is_a?(Hash) + event_data = {'body' => event_data.to_s} + end - def transport - @transport ||= Waffle::Base.new eval("Waffle::Transports::#{Waffle::Config.transport.capitalize}").new - end + event_data.merge!({'occured_at' => Time.now}) - def encoder - @encoder ||= eval("Waffle::Encoders::#{Waffle::Config.encoder.capitalize}") - end - - def occured(event_name = 'event', event_data = nil) - unless event_data.is_a? Hash - event_data = {'body' => event_data.to_s} + Waffle.publish(event_name, event_data) end - - event_data.merge!({'occured_at' => Time.now}) - - transport.publish event_name, encoder.encode(event_data) + alias :occurred :occured end - end end