public void onFailure()

in kinesis-data-analytics-sse/src/main/java/com/amazonaws/services/kinesisanalytics/SSESource.java [170:181]

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

        public void onFailure(@NotNull EventSource eventSource, Throwable t, Response response) {
            if (t != null) {
                logger.error("SSESource Error: " + t.getMessage());
                StringWriter sw = new StringWriter();
                PrintWriter pw = new PrintWriter(sw);
                t.printStackTrace(pw);
                logger.error("SSESource Error Trace: " + sw);
                if (t instanceof StreamResetException && t.getMessage().contains("NO_ERROR")) {
                    isConnected = false;
                }
            }
        }