class MagicPipe::Senders::Base
Public Class Methods
new(object, topic, wrapper, time, codec, transport, config, metrics)
click to toggle source
object should be something similar to an ActiveModel::Serializer or ActiveRecord object.
# File lib/magic_pipe/senders/base.rb, line 8 def initialize(object, topic, wrapper, time, codec, transport, config, metrics) @object = object @topic = topic @wrapper = wrapper @time = time @codec = codec @transport = transport @config = config @metrics = metrics end
Public Instance Methods
call()
click to toggle source
# File lib/magic_pipe/senders/base.rb, line 19 def call raise NotImplementedError end