lib/waffle/transports/redis.rb in waffle-0.4.0 vs lib/waffle/transports/redis.rb in waffle-0.5.0

@@ -1,28 +1,28 @@
 module Waffle
   module Transports
     class Redis < Base
       attr_reader :db
 
-      def publish(flow = 'events', message = '')
-        db.publish(flow, Waffle.encoder.encode(message))
+      protected
+      def publish_impl(flow = 'events', message = '')
+        db.publish(flow, encoder.encode(message))
       end
 
-      def subscribe(flow = 'events')
+      def subscribe_impl(flow = 'events')
         db.subscribe(*flow) do |on|
           on.message do |channel, message|
-            yield(channel, Waffle.encoder.decode(message))
+            yield(channel, encoder.decode(message))
           end
         end
       end
 
       def connection_exceptions
         [Errno::ECONNREFUSED, Errno::ECONNRESET]
       end
 
-      protected
       def do_connect
-        @db = ::Redis.new(:url => Waffle.config.url)
+        @db = ::Redis.new(:url => config.url)
       end
     end
   end
 end