public void onTaskError()

in src/main/java/com/revo/deployr/rbroker/example/service/FraudService.java [236:253]

• 11 lines of code
• 2 McCabe index (conditional complexity)

    public void onTaskError(RTask rTask, Throwable throwable) {
        RBrokerStatsHelper.printRTaskResult(rTask, null, throwable);
        // Push FraudScore message over STOMP Web Socket to clients.
        FraudScore fraudScore = buildFraudScore(rTask, null);
        simpMessagingTemplate.convertAndSend(FRAUDMSGTOPIC, fraudScore);

        if(rBroker != null & !rBroker.isConnected()) {
            /*
             * If RTask is failing because the RBroker runtime has
             * lost it's connection to the DeployR server then broadcast
             * an alert message indicating problem and potential remedy.
             */
            String msg = "The RBroker runtime has lost it's connection " +
                "to DeployR server. Try building a new pool using Resize.";
            String cause = throwable.getMessage();
            alertClient(msg, cause, true);
        }
    }