lib/waffle/event.rb in waffle-0.1.3 vs lib/waffle/event.rb in waffle-0.2.1

@@ -9,25 +9,25 @@
       def occured(*args)
         self.instance.occured(*args)
       end
     end
 
-    def config
-      @config ||= Waffle::Configuration.new
+    def transport
+      @transport ||= Waffle::Base.new eval("Waffle::Transports::#{Waffle::Config.transport.capitalize}").new
     end
 
-    def transport
-      @transport ||= Waffle::Base.new eval("Waffle::Strategies::#{config.strategy.capitalize}").new(config)
+    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}
       end
 
       event_data.merge!({'occured_at' => Time.now})
 
-      transport.publish event_name, Waffle::Utils.encode(event_data)
+      transport.publish event_name, encoder.encode(event_data)
     end
 
   end
 end