lib/dispatch-rider/notification_services/base.rb in dispatch-rider-1.4.2 vs lib/dispatch-rider/notification_services/base.rb in dispatch-rider-1.5.0

@@ -28,11 +28,11 @@
         raise NotImplementedError
       end
 
       def publish(options)
         channels(options[:to]).each do |channel|
-          channel.publish(serialize(message(options[:message])))
+          channel.publish(serialize(options[:message]))
         end
       end
 
       def channels(names)
         Array(names).map { |name| channel(name) }
@@ -40,18 +40,10 @@
 
       def channel(name)
         raise NotImplementedError
       end
 
-      def message_builder
-        DispatchRider::Message
-      end
-
       private
-
-      def message(attrs)
-        message_builder.new(attrs)
-      end
 
       def serialize(item)
         item.to_json
       end
     end