in lib/aws/kclrb/checkpointer.rb [66:86]
def checkpoint(sequence_number=nil)
@io_proxy.write_action('checkpoint', 'sequenceNumber' => sequence_number)
action = @io_proxy.read_action
if action && action['action'] == 'checkpoint'
raise CheckpointError.new(action['error']) if action['error']
else
raise CheckpointError.new('InvalidStateException')
end
end