private void dropFile()

in CustomKeystore/src/main/java/com/amazonaws/services/kinesisanalytics/CustomFlinkKafkaConsumer.java [32:61]

• 26 lines of code
• 4 McCabe index (conditional complexity)

    private void dropFile(String destFolder) throws Exception
    {
        InputStream input = null;
        OutputStream outStream = null;

        try {
            ClassLoader classLoader = Thread.currentThread().getContextClassLoader();
            input = classLoader.getResourceAsStream("kafka.client.truststore.jks");
            byte[] buffer = new byte[input.available()];
            input.read(buffer);

            File destDir = new File(destFolder);
            File targetFile = new File(destDir, "kafka.client.truststore.jks");
            outStream = new FileOutputStream(targetFile);
            outStream.write(buffer);
            outStream.flush();
        }
        catch (Exception ex)
        {
            System.out.println(ex.getMessage());

            if(input != null) {
                input.close();
            }

            if(outStream != null) {
                outStream.close();
            }
        }
    }