class Bricolage::StreamingLoad::DispatcherMessage
Public Class Methods
get_concrete_class(msg, rec)
click to toggle source
# File lib/bricolage/streamingload/dispatchermessage.rb, line 10 def DispatcherMessage.get_concrete_class(msg, rec) case when rec['eventName'] == 'shutdown' then ShutdownDispatcherMessage when rec['eventName'] == 'dispatch' then DispatchDispatcherMessage when rec['eventName'] == 'flushtable' then FlushTableDispatcherMessage when rec['eventName'] == 'checkpoint' then CheckPointDispatcherMessage when !!rec['s3'] then S3ObjectDispatcherMessage else UnknownSQSMessage end end
Public Instance Methods
data?()
click to toggle source
# File lib/bricolage/streamingload/dispatchermessage.rb, line 25 def data? false end
message_type()
click to toggle source
# File lib/bricolage/streamingload/dispatchermessage.rb, line 21 def message_type raise "#{self.class}\#message_type must be implemented" end