in src/main/java/com/revo/deployr/rbroker/example/util/RBrokerStatsHelper.java [35:67]
public static void printRBrokerStats(RBrokerRuntimeStats stats,
int maxConcurrency) {
log.info("RBroker Activity Summary");
log.info("RBroker: Max Concurrency [ " +
maxConcurrency + " ]");
log.info("RBroker: Total Tasks Run [ " +
stats.totalTasksRun + " ]");
log.info("RBroker: Tasks Ok [ " +
stats.totalTasksRunToSuccess + " ] Fail [ " +
stats.totalTasksRunToFailure + " ]");
long displayAvgTimeOnCode = 0L;
long displayAvgTimeOnServer = 0L;
long displayAvgTimeOnCall = 0L;
if(stats.totalTasksRunToSuccess > 0) {
displayAvgTimeOnCode =
stats.totalTimeTasksOnCode/stats.totalTasksRunToSuccess;
displayAvgTimeOnServer =
stats.totalTimeTasksOnServer/stats.totalTasksRunToSuccess;
displayAvgTimeOnCall =
stats.totalTimeTasksOnCall/stats.totalTasksRunToSuccess;
}
log.info("RBroker: Task Average Time On Code [ " +
displayAvgTimeOnCode + " ]");
log.info("RBroker: Task Average Time On Server [ " +
displayAvgTimeOnServer + " ]");
log.info("RBroker: Task Average Time On Call [ " +
displayAvgTimeOnCall + " ]\n");
}