class Bricolage::StreamingLoad::LoaderMessage

Public Class Methods

get_concrete_class(msg, rec) click to toggle source
# File lib/bricolage/streamingload/loadermessage.rb, line 9
def LoaderMessage.get_concrete_class(msg, rec)
  case
  when rec['eventName'] == 'streaming_load_v3' then StreamingLoadV3LoaderMessage
  else UnknownSQSMessage
  end
end

Public Instance Methods

data?() click to toggle source
# File lib/bricolage/streamingload/loadermessage.rb, line 20
def data?
  false
end
message_type() click to toggle source
# File lib/bricolage/streamingload/loadermessage.rb, line 16
def message_type
  raise "#{self.class}\#message_type must be implemented"
end