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