class Bricolage::StreamingLoad::CheckPointDispatcherMessage
Flushes all tables and shutdown
Public Class Methods
create()
click to toggle source
Calls superclass method
Bricolage::SQSMessage::create
# File lib/bricolage/streamingload/dispatchermessage.rb, line 53 def CheckPointDispatcherMessage.create super name: 'checkpoint' end
parse_sqs_record(msg, rec)
click to toggle source
# File lib/bricolage/streamingload/dispatchermessage.rb, line 57 def CheckPointDispatcherMessage.parse_sqs_record(msg, rec) {} end
Public Instance Methods
init_message(dummy: nil)
click to toggle source
# File lib/bricolage/streamingload/dispatchermessage.rb, line 63 def init_message(dummy: nil) end