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