diff --git a/src/main/java/org/gcube/accounting/service/AccountingServiceInitializer.java b/src/main/java/org/gcube/accounting/service/AccountingServiceInitializer.java index a62d237..20118ca 100644 --- a/src/main/java/org/gcube/accounting/service/AccountingServiceInitializer.java +++ b/src/main/java/org/gcube/accounting/service/AccountingServiceInitializer.java @@ -1,5 +1,6 @@ package org.gcube.accounting.service; +import org.gcube.accounting.aggregator.RegexRulesAggregator; import org.gcube.accounting.analytics.persistence.AccountingPersistenceQueryFactory; import org.gcube.accounting.persistence.AccountingPersistenceFactory; import org.gcube.common.authorization.client.Constants; @@ -11,6 +12,9 @@ import org.gcube.smartgears.ApplicationManager; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/** + * @author Luca Frosini (ISTI - CNR) + */ public class AccountingServiceInitializer implements ApplicationManager { private static Logger logger = LoggerFactory.getLogger(AccountingServiceInitializer.class); @@ -44,6 +48,9 @@ public class AccountingServiceInitializer implements ApplicationManager { AccountingPersistenceFactory.getPersistence(); // Initializing the persistence connector used for query AccountingPersistenceQueryFactory.getInstance(); + + // Initializing RegexRulesAggregator + RegexRulesAggregator.getInstance().start(); } public void onShutdown() { @@ -60,6 +67,8 @@ public class AccountingServiceInitializer implements ApplicationManager { // Closing the persistence connector used for query AccountingPersistenceQueryFactory.getInstance().close(); + RegexRulesAggregator.getInstance().stop(); + logger.trace("\n-------------------------------------------------------\n" + "Accounting Service Stopped Successfully on context {}\n" + "-------------------------------------------------------", context);