summaryrefslogtreecommitdiffstats
path: root/common/src/main/java/org/onap/so/utils/ExternalTaskServiceUtils.java
diff options
context:
space:
mode:
authorPlummer, Brittany <brittany.plummer@att.com>2020-03-04 21:19:08 -0500
committerBenjamin, Max (mb388a) <mb388a@att.com>2020-03-05 10:43:49 -0500
commit0d63836c2eaa7267d55a4757fd83ea1b4b1c8bb2 (patch)
treee7757b4bae25083a08f2a8c0846f1ca823ef19ed /common/src/main/java/org/onap/so/utils/ExternalTaskServiceUtils.java
parent93fd7052a09fecf632bfde52debc772b1686d634 (diff)
create custom spring aop annotation for logging
Added annotation for setting up scheduled tasks logs Added new annotation to scheduledTasks Moved annotation setup to logging-library Issue-ID: SO-2713 Signed-off-by: Benjamin, Max (mb388a) <mb388a@att.com> Change-Id: I7080c4bb289e454f14167631e2601c954389c0ef
Diffstat (limited to 'common/src/main/java/org/onap/so/utils/ExternalTaskServiceUtils.java')
-rw-r--r--common/src/main/java/org/onap/so/utils/ExternalTaskServiceUtils.java2
1 files changed, 2 insertions, 0 deletions
diff --git a/common/src/main/java/org/onap/so/utils/ExternalTaskServiceUtils.java b/common/src/main/java/org/onap/so/utils/ExternalTaskServiceUtils.java
index 4f13cec8f4..035ad1dc81 100644
--- a/common/src/main/java/org/onap/so/utils/ExternalTaskServiceUtils.java
+++ b/common/src/main/java/org/onap/so/utils/ExternalTaskServiceUtils.java
@@ -6,6 +6,7 @@ import java.util.concurrent.ConcurrentHashMap;
import org.camunda.bpm.client.ExternalTaskClient;
import org.camunda.bpm.client.interceptor.ClientRequestInterceptor;
import org.camunda.bpm.client.interceptor.auth.BasicAuthProvider;
+import org.onap.logging.filter.base.ScheduledLogging;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -53,6 +54,7 @@ public class ExternalTaskServiceUtils {
return Integer.parseInt(env.getProperty("workflow.topics.maxClients", "3"));
}
+ @ScheduledLogging
@Scheduled(fixedDelay = 30000)
public void checkAllClientsActive() {
getClients().stream().filter(client -> !client.isActive()).forEach(ExternalTaskClient::start);