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