BRMSGateway/src/main/java/org/onap/policy/brmsInterface/BRMSGateway.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP Policy Engine
   4  * ================================================================================
   5  * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.policy.brmsInterface;
  22
  23 import org.onap.policy.api.NotificationScheme;
  24 import org.onap.policy.api.PolicyEngine;
  25 import org.onap.policy.api.PolicyException;
  26 import org.onap.policy.common.logging.flexlogger.FlexLogger;
  27 import org.onap.policy.common.logging.flexlogger.Logger;
  28 import org.onap.policy.xacml.api.XACMLErrorConstants;
  29
  30 /**
  31  * BRMSGateway: This application acts as the Gateway interface between the PDP XACML and PDP Drools. The listens for
  32  * BRMS based policies and pushes them to the specified Policy Repository, from where the PDP Drools reads the Rule Jar.
  33  *
  34  * @version 0.1
  35  */
  36 public class BRMSGateway {
  37
  38     private static final Logger logger = FlexLogger.getLogger(BRMSGateway.class);
  39     private static final String CONFIGFILE = "config.properties";
  40
  41     private static PolicyEngine policyEngine = null;
  42
  43     public static void main(String[] args) throws Exception {
  44         // Initialize Handler.
  45         logger.info("Initializing BRMS Handler");
  46         BRMSHandler bRMSHandler = null;
  47         try {
  48             bRMSHandler = new BRMSHandler(CONFIGFILE);
  49         } catch (PolicyException e) {
  50             logger.error("Check your property file: " + e.getMessage(), e);
  51             System.exit(1);
  52         }
  53
  54         // Set Handler with Auto Notification and initialize policyEngine
  55         try {
  56             logger.info("Initializing policyEngine with Auto Notifications");
  57             policyEngine = new PolicyEngine(CONFIGFILE, NotificationScheme.AUTO_ALL_NOTIFICATIONS, bRMSHandler);
  58         } catch (Exception e) {
  59             logger.error(XACMLErrorConstants.ERROR_UNKNOWN + "Error while Initializing Policy Engine " + e.getMessage(),
  60                     e);
  61         }
  62
  63         // Keep Running....
  64         Runnable runnable = () -> {
  65             while (true) {
  66                 try {
  67                     Thread.sleep(30000);
  68                 } catch (InterruptedException e) {
  69                     logger.error(XACMLErrorConstants.ERROR_SYSTEM_ERROR + "Thread Exception " + e.getMessage());
  70                     Thread.currentThread().interrupt();
  71                 }
  72             }
  73         };
  74         Thread thread = new Thread(runnable);
  75         thread.start();
  76     }
  77
  78     public static PolicyEngine getPolicyEngine() {
  79         return policyEngine;
  80     }
  81 }