[POLICY-8] cleaned up unused code

Change-Id: Ifebf67db574e1c4eadf9d50ca0f178ab7ddba033
Signed-off-by: Jorge Hernandez <jh1730@att.com>

21 files changed, 0 insertions, 4941 deletions

diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/core/DbAudit.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/core/DbAudit.java
deleted file mode 100644
index f534cc22..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/core/DbAudit.java
+++ /dev/null
@@ -1,210 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.core;
-
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.PreparedStatement;
-import java.sql.ResultSet;
-import java.util.Properties;
-import java.util.UUID;
-
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-import org.openecomp.policy.common.logging.eelf.MessageCodes;
-import org.openecomp.policy.drools.persistence.DroolsPersistenceProperties;
-
-/**
- * This class audits the database
- */
-public class DbAudit extends DroolsPDPIntegrityMonitor.AuditBase
-{
-	// get an instance of logger 
-  private static Logger  logger = FlexLogger.getLogger(DbAudit.class);	
-  // single global instance of this audit object
-  static private DbAudit instance = new DbAudit();
-
-  // This indicates if 'CREATE TABLE IF NOT EXISTS Audit ...' should be
-  // invoked -- doing this avoids the need to create the table in advance.
-  static private boolean createTableNeeded = true;
-
-  /**
-   * @return the single 'DbAudit' instance
-   */
-  static DroolsPDPIntegrityMonitor.AuditBase getInstance()
-  {
-	return(instance);
-  }
-
-  /**
-   * Constructor - set the name to 'Database'
-   */
-  private DbAudit()
-  {
-	super("Database");
-  }
-
-  /**
-   * Invoke the audit
-   *
-   * @param properties properties to be passed to the audit
-   */
-  @Override
-	public void invoke(Properties droolsPersistenceProperties)
-  {
-	logger.info("Running 'DbAudit.invoke'");
-	boolean isActive = true;
-	String dbAuditIsActive = IntegrityMonitorProperties.getProperty("db.audit.is.active");
-	logger.debug("DbAudit.invoke: dbAuditIsActive = " + dbAuditIsActive);
-	
-	if (dbAuditIsActive != null) {
-		try {
-			isActive = Boolean.parseBoolean(dbAuditIsActive.trim());
-		} catch (NumberFormatException e) {
-			logger.warn("DbAudit.invoke: Ignoring invalid property: db.audit.is.active = " + dbAuditIsActive);
-		}
-	}
-	
-	if(!isActive){
-		logger.info("DbAudit.invoke: exiting because isActive = " + isActive);
-		return;
-	}
-	
-	// fetch DB properties from properties file -- they are already known
-	// to exist, because they were verified by the 'IntegrityMonitor'
-	// constructor
-	String url = droolsPersistenceProperties.getProperty(DroolsPersistenceProperties.DB_URL);
-	String user = droolsPersistenceProperties.getProperty(DroolsPersistenceProperties.DB_USER);
-	String password =
-			droolsPersistenceProperties.getProperty(DroolsPersistenceProperties.DB_PWD);
-
-	// connection to DB
-	Connection connection = null;
-
-	// supports SQL operations
-	PreparedStatement statement = null;
-	ResultSet rs = null;
-
-	// operation phase currently running -- used to construct an error
-	// message, if needed
-	String phase = null;
-
-	try
-	  {
-		// create connection to DB
-		phase = "creating connection";
-		logger.info("DbAudit: Creating connection to " + url);
-
-		connection = DriverManager.getConnection(url, user, password);
-
-		// create audit table, if needed
-		if (createTableNeeded)
-		  {
-			phase = "create table";
-			logger.info("DbAudit: Creating 'Audit' table, if needed");
-			statement = connection.prepareStatement
-			  ("CREATE TABLE IF NOT EXISTS Audit (\n"
-			   + " name varchar(64) DEFAULT NULL,\n"
-			   + " UNIQUE KEY name (name)\n"
-			   + ") DEFAULT CHARSET=latin1;");
-			statement.execute();
-			statement.close();
-			createTableNeeded = false;
-		  }
-
-		// insert an entry into the table
-		phase = "insert entry";
-		String key = UUID.randomUUID().toString();
-		statement = connection.prepareStatement
-		  ("INSERT INTO Audit (name) VALUES (?)");
-		statement.setString(1, key);
-		statement.executeUpdate();
-		statement.close();
-
-		// fetch the entry from the table
-		phase = "fetch entry";
-		statement = connection.prepareStatement
-		  ("SELECT name FROM Audit WHERE name = ?");
-		statement.setString(1, key);
-		rs = statement.executeQuery();
-		if (rs.first())
-		  {
-			// found entry
-			logger.info("DbAudit: Found key " + rs.getString(1));
-		  }
-		else
-		  {
-			logger.error
-			  ("DbAudit: can't find newly-created entry with key " + key);
-			setResponse("Can't find newly-created entry");
-		  }
-		statement.close();
-
-		// delete entries from table
-		phase = "delete entry";
-		statement = connection.prepareStatement
-		  ("DELETE FROM Audit WHERE name = ?");
-		statement.setString(1, key);
-		statement.executeUpdate();
-		statement.close();
-		statement = null;
-	  }
-	catch (Exception e)
-	  {
-		String message = "DbAudit: Exception during audit, phase = " + phase;
-		logger.error(MessageCodes.EXCEPTION_ERROR, e, message);
-		setResponse(message);
-	  }
-	finally
-	  {
-		if (rs != null)
-		  {
-			try
-			  {
-				rs.close();
-			  }
-			catch (Exception e)
-			  {
-			  }
-		  }
-		if (statement != null)
-		  {
-			try
-			  {
-				statement.close();
-			  }
-			catch (Exception e)
-			  {
-			  }
-		  }
-		if (connection != null)
-		  {
-			try
-			  {
-				connection.close();
-			  }
-			catch (Exception e)
-			  {
-			  }
-		  }
-	  }
-  }
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/core/DroolsPDPIntegrityMonitor.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/core/DroolsPDPIntegrityMonitor.java
deleted file mode 100644
index dc63d719..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/core/DroolsPDPIntegrityMonitor.java
+++ /dev/null
@@ -1,439 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.core;
-
-import java.io.File;
-import java.io.FileInputStream;
-import java.net.InetSocketAddress;
-import java.util.ArrayList;
-import java.util.Properties;
-
-import org.openecomp.policy.common.im.IntegrityMonitor;
-import org.openecomp.policy.common.logging.eelf.MessageCodes;
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-import org.openecomp.policy.common.logging.flexlogger.PropertyUtil;
-import org.openecomp.policy.drools.http.server.HttpServletServer;
-import org.openecomp.policy.drools.persistence.XacmlPersistenceProperties;
-import org.openecomp.policy.drools.properties.Startable;
-
-/**
- * This class extends 'IntegrityMonitor' for use in the 'Drools PDP'
- * virtual machine. The included audits are 'Database' and 'Repository'.
- */
-public class DroolsPDPIntegrityMonitor extends IntegrityMonitor
-{
-	
-	// get an instance of logger 
-  private static Logger  logger = FlexLogger.getLogger(DroolsPDPIntegrityMonitor.class);	
-
-  // static global instance
-  static private DroolsPDPIntegrityMonitor im = null;
-
-  // list of audits to run
-  static private AuditBase[] audits =
-	new AuditBase[]{DbAudit.getInstance(), RepositoryAudit.getInstance()};
-
-  // save initialization properties
-  private Properties droolsPersistenceProperties = null;
-  
-  /**
-   * Static initialization -- create Drools Integrity Monitor, and
-   * an HTTP server to handle REST 'test' requests
-   */
-  static public DroolsPDPIntegrityMonitor init(String configDir) throws Exception
-  {
-	  	  
-	logger.info("init: Entering and invoking PropertyUtil.getProperties() on '"
-				+ configDir + "'");
-		
-	// read in properties
-	Properties integrityMonitorProperties =
-	  PropertyUtil.getProperties(configDir + "/IntegrityMonitor.properties");
-	Properties droolsPersistenceProperties =
-	  PropertyUtil.getProperties(configDir + "/droolsPersistence.properties");
-	Properties xacmlPersistenceProperties =
-	  PropertyUtil.getProperties(configDir + "/xacmlPersistence.properties");
-
-	// fetch and verify definitions of some properties
-	// (the 'IntegrityMonitor' constructor does some additional verification)
-	String resourceName = integrityMonitorProperties.getProperty("resource.name");
-	String hostPort = integrityMonitorProperties.getProperty("hostPort");
-	String fpMonitorInterval = integrityMonitorProperties.getProperty("fp_monitor_interval");
-	String failedCounterThreshold = integrityMonitorProperties.getProperty("failed_counter_threshold");
-	String testTransInterval = integrityMonitorProperties.getProperty("test_trans_interval");
-	String writeFpcInterval = integrityMonitorProperties.getProperty("write_fpc_interval");
-	String siteName = integrityMonitorProperties.getProperty("site_name");
-	String nodeType = integrityMonitorProperties.getProperty("node_type");
-	String dependencyGroups = integrityMonitorProperties.getProperty("dependency_groups");
-	String droolsJavaxPersistenceJdbcDriver = droolsPersistenceProperties.getProperty("javax.persistence.jdbc.driver");
-	String droolsJavaxPersistenceJdbcUrl = droolsPersistenceProperties.getProperty("javax.persistence.jdbc.url");
-	String droolsJavaxPersistenceJdbcUser = droolsPersistenceProperties.getProperty("javax.persistence.jdbc.user");
-	String droolsJavaxPersistenceJdbcPassword = droolsPersistenceProperties.getProperty("javax.persistence.jdbc.password");	
-	String xacmlJavaxPersistenceJdbcDriver = xacmlPersistenceProperties.getProperty("javax.persistence.jdbc.driver");
-	String xacmlJavaxPersistenceJdbcUrl = xacmlPersistenceProperties.getProperty("javax.persistence.jdbc.url");
-	String xacmlJavaxPersistenceJdbcUser = xacmlPersistenceProperties.getProperty("javax.persistence.jdbc.user");
-	String xacmlJavaxPersistenceJdbcPassword = xacmlPersistenceProperties.getProperty("javax.persistence.jdbc.password");
-	
-	if (resourceName == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'resource.name'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'resource.name'"));
-	  }
-	if (hostPort == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'hostPort'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'hostPort'"));
-	  }
-	if (fpMonitorInterval == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'fp_monitor_interval'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'fp_monitor_interval'"));
-	  }	
-	if (failedCounterThreshold == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'failed_counter_threshold'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'failed_counter_threshold'"));
-	  }	
-	if (testTransInterval == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'test_trans_interval'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'test_trans_interval'"));
-	  }	
-	if (writeFpcInterval == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'write_fpc_interval'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'write_fpc_interval'"));
-	  }	
-	if (siteName == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'site_name'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'site_name'"));
-	  }	
-	if (nodeType == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'node_type'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'node_type'"));
-	  }	
-	if (dependencyGroups == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'dependency_groups'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'dependency_groups'"));
-	  }	
-	if (droolsJavaxPersistenceJdbcDriver == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'javax.persistence.jbdc.driver for drools DB'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'javax.persistence.jbdc.driver for drools DB'"));
-	  }		
-	if (droolsJavaxPersistenceJdbcUrl == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'javax.persistence.jbdc.url  for drools DB'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'javax.persistence.jbdc.url for drools DB'"));
-	  }			
-	if (droolsJavaxPersistenceJdbcUser == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'javax.persistence.jbdc.user for drools DB'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'javax.persistence.jbdc.user for drools DB'"));
-	  }			
-	if (droolsJavaxPersistenceJdbcPassword == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'javax.persistence.jbdc.password for drools DB'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'javax.persistence.jbdc.password for drools DB'"));
-	  }	
-	if (xacmlJavaxPersistenceJdbcDriver == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'javax.persistence.jbdc.driver for xacml DB'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'javax.persistence.jbdc.driver for xacml DB'"));
-	  }		
-	if (xacmlJavaxPersistenceJdbcUrl == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'javax.persistence.jbdc.url  for xacml DB'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'javax.persistence.jbdc.url  for xacml DB'"));
-	  }			
-	if (xacmlJavaxPersistenceJdbcUser == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'javax.persistence.jbdc.user for xacml DB'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'javax.persistence.jbdc.user for xacml DB'"));
-	  }			
-	if (xacmlJavaxPersistenceJdbcPassword == null)
-	  {
-		logger.error("init: Missing IntegrityMonitor property: 'javax.persistence.jbdc.password for xacml DB'");
-		throw(new Exception
-			  ("Missing IntegrityMonitor property: 'javax.persistence.jbdc.password'  for xacml DB'"));
-	  }		
-
-	logger.info("init: loading consolidatedProperties");
-	Properties consolidatedProperties = new Properties();
-	consolidatedProperties.load(new FileInputStream(new File(configDir + "/IntegrityMonitor.properties")));
-	consolidatedProperties.load(new FileInputStream(new File(configDir + "/xacmlPersistence.properties")));
-	// verify that consolidatedProperties has properties from both properties files.
-	logger.info("init: PDP_INSTANCE_ID=" + consolidatedProperties.getProperty(IntegrityMonitorProperties.PDP_INSTANCE_ID));
-	logger.info("init: DB_URL=" + consolidatedProperties.getProperty(XacmlPersistenceProperties.DB_URL));
-
-	// Now that we've validated the properties, create Drools Integrity Monitor
-	// with these properties.
-	im = new DroolsPDPIntegrityMonitor(resourceName,
-				consolidatedProperties, droolsPersistenceProperties);
-	logger.info("init: New DroolsPDPIntegrityMonitor instantiated, hostPort=" + hostPort);
-
-	// determine host and port for HTTP server
-	int index = hostPort.lastIndexOf(':');
-	InetSocketAddress addr;
-
-	if (index < 0)
-	  {
-		addr = new InetSocketAddress(Integer.valueOf(hostPort));
-	  }
-	else
-	  {
-		addr = new InetSocketAddress
-		  (hostPort.substring(0, index),
-		   Integer.valueOf(hostPort.substring(index + 1)));
-	  }
-
-	// create http server
-	try {
-		logger.info("init: Starting HTTP server, addr=" + addr);
-		IntegrityMonitorRestServer server = new IntegrityMonitorRestServer();
-		
-		server.init(integrityMonitorProperties);
-
-		System.out.println("init: Started server on hostPort=" + hostPort);
-	} catch (Exception e) {
-			if (PolicyContainer.isUnitTesting) {
-				System.out
-						.println("init: Caught Exception attempting to start server on hostPort="
-								+ hostPort + ", message=" + e.getMessage());
-		} else {
-			throw e;
-		}
-	}
-	
-	logger.info("init: Exiting and returning DroolsPDPIntegrityMonitor");
-	return im;
-  }
-
-  /**
-   * Constructor - pass arguments to superclass, but remember properties
-   * @param resourceName unique name of this Integrity Monitor
-   * @param url the JMX URL of the MBean server
-   * @param properties properties used locally, as well as by
-   *	'IntegrityMonitor'
-   * @throws Exception (passed from superclass)
-   */
-	private DroolsPDPIntegrityMonitor(String resourceName,
-			Properties consolidatedProperties,
-			Properties droolsPersistenceProperties) throws Exception {
-	super(resourceName, consolidatedProperties);
-	this.droolsPersistenceProperties = droolsPersistenceProperties;
-  }
-
-  /**
-   * Run tests (audits) unique to Drools PDP VM (Database + Repository)
-   */
-  @Override
-	public void subsystemTest() throws Exception
-  {
-	logger.info("DroolsPDPIntegrityMonitor.subsystemTest called");
-
-	// clear all responses (non-null values indicate an error)
-	for (AuditBase audit : audits)
-	  {
-		audit.setResponse(null);
-	  }
-
-	// invoke all of the audits
-	for (AuditBase audit : audits)
-	  {
-		try
-		  {
-			// invoke the audit (responses are stored within the audit object)
-			audit.invoke(droolsPersistenceProperties);
-		  }
-		catch (Exception e)
-		  {
-			logger.error(MessageCodes.EXCEPTION_ERROR, e,
-							   audit.getName() + " audit error");
-			if (audit.getResponse() == null)
-			  {
-				// if there is no current response, use the exception message
-				audit.setResponse(e.getMessage());
-			  }
-		  }
-	  }
-	
-	  // will contain list of subsystems where the audit failed
-	  String responseMsg = "";
-
-	  // Loop through all of the audits, and see which ones have failed.
-	  // NOTE: response information is stored within the audit objects
-	  // themselves -- only one can run at a time.
-	  for (AuditBase audit : audits)
-		{
-		  String response = audit.getResponse();
-		  if (response != null)
-			{
-			  // the audit has failed -- add subsystem and 
-			  // and 'responseValue' with the new information
-			  responseMsg = responseMsg.concat("\n" + audit.getName() + ": " + response);
-			}
-		}
-	  
-	  if(!responseMsg.isEmpty()){
-		  throw new Exception(responseMsg);
-	  }
-  }
-
-  /* ============================================================ */
-
-  /**
-   * This is the base class for audits invoked in 'subsystemTest'
-   */
-  static public abstract class AuditBase
-  {
-	// name of the audit
-	protected String name;
-
-	// non-null indicates the error response
-	protected String response;
-
-	/**
-	 * Constructor - initialize the name, and clear the initial response
-	 * @param name name of the audit
-	 */
-	public AuditBase(String name)
-	{
-	  this.name = name;
-	  this.response = null;
-	}
-
-	/**
-	 * @return the name of this audit
-	 */
-	public String getName()
-	{
-	  return(name);
-	}
-
-	/**
-	 * @return the response String (non-null indicates the error message)
-	 */
-	public String getResponse()
-	{
-	  return(response);
-	}
-
-	/**
-	 * Set the response string to the specified value
-	 * @param value the new value of the response string (null = no errors)
-	 */
-	public void setResponse(String value)
-	{
-	  response = value;
-	}
-
-	/**
-	 * Abstract method to invoke the audit
-	 * @param droolsPersistenceProperties Used for DB access
-	 * @throws Exception passed in by the audit
-	 */
-	abstract void invoke(Properties droolsPersistenceProperties) throws Exception;
-  }
-  
-  	public static class IntegrityMonitorRestServer implements Startable {
-  		protected volatile HttpServletServer server = null;
-  		protected volatile Properties integrityMonitorRestServerProperties = null;
-  		
-  		public void init(Properties props) {
-			this.integrityMonitorRestServerProperties = props;
-			this.start();
-  		}
-  		
-  		@Override
-		public boolean start() throws IllegalStateException {
-			try {
-				ArrayList<HttpServletServer> servers = HttpServletServer.factory.build(integrityMonitorRestServerProperties);
-				
-				if (!servers.isEmpty()) {
-					server = servers.get(0);
-					
-					try {
-						server.start();
-					} catch (Exception e) {
-						e.printStackTrace();
-					}
-				}
-			} catch (Exception e) {
-				return false;
-			}
-			
-			return true;
-		}
-
-  		@Override
-		public boolean stop() throws IllegalStateException {
-			try {
-				server.stop();
-			} catch (Exception e) {
-				e.printStackTrace();
-			}
-			
-			return true;
-		}
-
-		@Override
-		public void shutdown() throws IllegalStateException {
-			this.stop();
-		}
-		
-		@Override
-		public synchronized boolean isAlive() {
-			return this.integrityMonitorRestServerProperties != null;
-		}
-  	}
-
-	public static DroolsPDPIntegrityMonitor getInstance() throws Exception{
-		logger.info("getInstance() called");
-		if (im == null) {
-			String msg = "No DroolsPDPIntegrityMonitor instance exists."
-					+ " Please use the method DroolsPDPIntegrityMonitor init(String configDir)";
-			throw new Exception(msg);
-		}else{
-			return im;
-		}
-	}
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/core/IntegrityMonitorProperties.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/core/IntegrityMonitorProperties.java
deleted file mode 100644
index e0df4e63..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/core/IntegrityMonitorProperties.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.core;
-
-import java.util.Properties;
-
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-
-public class IntegrityMonitorProperties {
-	// get an instance of logger 
-	private static Logger  logger = FlexLogger.getLogger(IntegrityMonitorProperties.class);
-		
-	public static final String PDP_INSTANCE_ID = "resource.name";
-	
-	public static final String PDP_CHECK_INVERVAL = "pdp.checkInterval";
-	public static final String PDP_UPDATE_INTERVAL = "pdp.updateInterval";
-	public static final String PDP_TIMEOUT = "pdp.timeout";
-	public static final String PDP_INITIAL_WAIT_PERIOD = "pdp.initialWait";
-
-	public static final String SITE_NAME = "site_name";
-	
-	private static Properties properties = null;
-	/*
-	 * Initialize the parameter values from the droolsPersitence.properties file values
-	 * 
-	 * This is designed so that the Properties object is obtained from the droolsPersistence.properties
-	 * file and then is passed to this method to initialize the value of the parameters.
-	 * This allows the flexibility of JUnit tests using getProperties(filename) to get the
-	 * properties while runtime methods can use getPropertiesFromClassPath(filename).
-	 * 
-	 */
-	public static void initProperties (Properties prop){
-		logger.info("IntegrityMonitorProperties.initProperties(Properties): entry");
-		logger.info("\n\nIntegrityMonitorProperties.initProperties: Properties = \n" + prop + "\n\n");
-		
-		properties = prop;
-	}
-
-	public static String getProperty(String key){
-		return properties.getProperty(key);
-	}
-	
-	public static Properties getProperties() {
-		return properties;
-	}
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/core/IntegrityMonitorRestManager.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/core/IntegrityMonitorRestManager.java
deleted file mode 100644
index 86b41ded..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/core/IntegrityMonitorRestManager.java
+++ /dev/null
@@ -1,111 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.core;
-
-import javax.ws.rs.GET;
-import javax.ws.rs.Path;
-import javax.ws.rs.core.Response;
-
-import org.openecomp.policy.common.logging.eelf.MessageCodes;
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-
-import io.swagger.annotations.Api;
-import io.swagger.annotations.ApiOperation;
-import io.swagger.annotations.ApiResponse;
-import io.swagger.annotations.ApiResponses;
-
-@Api(value = "test")
-	@Path("/")
-public class IntegrityMonitorRestManager {
-		private static Logger logger = FlexLogger.getLogger(IntegrityMonitorRestManager.class);	
-		private DroolsPDPIntegrityMonitor im;
-		
-		/**
-		 * Test interface for Integrity Monitor
-		 * 
-		 * @return Exception message if exception, otherwise empty
-		 */
-		@ApiOperation(
-			value = "Test endpoint for integrity monitor",
-			notes = "The TEST command is used to request data from a subcomponent "
-					+ "instance that can be used to determine its operational state. "
-					+ "A 200/success response status code should be returned if the "
-					+ "subcomponent instance is functioning properly and able to respond to requests.",
-			response = String.class)
-		@ApiResponses(value = {
-			@ApiResponse(
-				code = 200,
-				message = "Integrity monitor sanity check passed"),
-			@ApiResponse(
-				code = 500,
-				message = "Integrity monitor sanity check encountered an exception. This can indicate operational state disabled or administrative state locked")
-		})
-		@GET
-		@Path("test")
-		public Response test() {
-			logger.error("integrity monitor /test accessed");
-			// The responses are stored within the audit objects, so we need to
-			// invoke the audits and get responses before we handle another
-			// request.
-			synchronized (IntegrityMonitorRestManager.class) {
-				// will include messages associated with subsystem failures
-				StringBuilder body = new StringBuilder();
-
-				// 200=SUCCESS, 500=failure
-				int responseValue = 200;
-
-				if (im == null) {
-					try {
-						im = DroolsPDPIntegrityMonitor.getInstance();
-					} catch (Exception e) {
-						// TODO Auto-generated catch block
-						e.printStackTrace();
-						
-						body.append("\nException: " + e + "\n");
-						responseValue = 500;
-					}
-				}
-
-				if (im != null) {
-					try {
-						// call 'IntegrityMonitor.evaluateSanity()'
-						im.evaluateSanity();
-					} catch (Exception e) {
-						// this exception isn't coming from one of the audits,
-						// because those are caught in 'subsystemTest()'
-						logger.error(MessageCodes.EXCEPTION_ERROR, e, "DroolsPDPIntegrityMonitor.evaluateSanity()");
-
-						// include exception in HTTP response
-						body.append("\nException: " + e + "\n");
-						responseValue = 500;
-					}
-				}
-
-				// send response, including the contents of 'body'
-				// (which is empty if everything is successful)
-				if (responseValue == 200)
-					return Response.status(Response.Status.OK).build();
-				else
-					return Response.status(Response.Status.INTERNAL_SERVER_ERROR).entity(body.toString()).build();
-			}
-		}
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/core/RepositoryAudit.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/core/RepositoryAudit.java
deleted file mode 100644
index 76dadd9e..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/core/RepositoryAudit.java
+++ /dev/null
@@ -1,553 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.core;
-
-import java.io.File;
-import java.io.FileInputStream;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.nio.file.FileVisitResult;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.nio.file.SimpleFileVisitor;
-import java.nio.file.attribute.BasicFileAttributes;
-import java.util.LinkedList;
-import java.util.Properties;
-import java.util.concurrent.TimeUnit;
-
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-
-
-/**
- * This class audits the Maven repository
- */
-public class RepositoryAudit extends DroolsPDPIntegrityMonitor.AuditBase
-{
-  private static final long DEFAULT_TIMEOUT = 60;	// timeout in 60 seconds
-
-  // get an instance of logger
-  private static Logger  logger = FlexLogger.getLogger(RepositoryAudit.class);		
-  // single global instance of this audit object
-  static private RepositoryAudit instance = new RepositoryAudit();
-
-  /**
-   * @return the single 'RepositoryAudit' instance
-   */
-  static DroolsPDPIntegrityMonitor.AuditBase getInstance()
-  {
-	return(instance);
-  }
-
-  /**
-   * Constructor - set the name to 'Repository'
-   */
-  private RepositoryAudit()
-  {
-	super("Repository");
-  }
-
-  /**
-   * Invoke the audit
-   *
-   * @param properties properties to be passed to the audit
-   */
-  @Override
-	public void invoke(Properties properties)
-	throws IOException, InterruptedException
-  {
-	logger.info("Running 'RepositoryAudit.invoke'");
-	
-	boolean isActive = true;
-	boolean ignoreErrors = true;		// ignore errors by default
-	String repoAuditIsActive = IntegrityMonitorProperties.getProperty("repository.audit.is.active");
-	String repoAuditIgnoreErrors =
-	  IntegrityMonitorProperties.getProperty("repository.audit.ignore.errors");
-	logger.debug("RepositoryAudit.invoke: repoAuditIsActive = " + repoAuditIsActive
-				 + ", repoAuditIgnoreErrors = " + repoAuditIgnoreErrors);
-	
-	if (repoAuditIsActive != null) {
-		try {
-			isActive = Boolean.parseBoolean(repoAuditIsActive.trim());
-		} catch (NumberFormatException e) {
-			logger.warn("RepositoryAudit.invoke: Ignoring invalid property: repository.audit.is.active = " + repoAuditIsActive);
-		}
-	}
-	
-	if(!isActive){
-		logger.info("RepositoryAudit.invoke: exiting because isActive = " + isActive);
-		return;
-	}
-
-	if (repoAuditIgnoreErrors != null)
-	  {
-		try
-		  {
-			ignoreErrors = Boolean.parseBoolean(repoAuditIgnoreErrors.trim());
-		  }
-		catch (NumberFormatException e)
-		  {
-			logger.warn("RepositoryAudit.invoke: Ignoring invalid property: repository.audit.ignore.errors = " + repoAuditIgnoreErrors);
-		  }
-	  }
-
-	// Fetch repository information from 'IntegrityMonitorProperties'
-	String repositoryId =
-	  IntegrityMonitorProperties.getProperty("repository.audit.id");
-	String repositoryUrl =
-	  IntegrityMonitorProperties.getProperty("repository.audit.url");
-	String repositoryUsername =
-	  IntegrityMonitorProperties.getProperty("repository.audit.username");
-	String repositoryPassword =
-	  IntegrityMonitorProperties.getProperty("repository.audit.password");
-	boolean upload =
-	  (repositoryId != null && repositoryUrl != null
-	   && repositoryUsername != null && repositoryPassword != null);
-
-	// used to incrementally construct response as problems occur
-	// (empty = no problems)
-	StringBuilder response = new StringBuilder();
-
-	long timeoutInSeconds = DEFAULT_TIMEOUT;
-	String timeoutString =
-	  IntegrityMonitorProperties.getProperty("repository.audit.timeout");
-	if (timeoutString != null && !timeoutString.isEmpty())
-	  {
-		try
-		  {
-			timeoutInSeconds = Long.valueOf(timeoutString);
-		  }
-		catch (NumberFormatException e)
-		  {
-			logger.error
-			  ("RepositoryAudit: Invalid 'repository.audit.timeout' value: '"
-			   + timeoutString + "'");
-			if (!ignoreErrors)
-			  {
-				response.append("Invalid 'repository.audit.timeout' value: '")
-				  .append(timeoutString).append("'\n");
-				setResponse(response.toString());
-			  }
-		  }
-	  }
-
-	// artifacts to be downloaded
-	LinkedList<Artifact> artifacts = new LinkedList<Artifact>();
-
-	/*
-	 * 1) create temporary directory
-	 */
-	Path dir = Files.createTempDirectory("auditRepo");
-	logger.info("RepositoryAudit: temporary directory = " + dir);
-
-	// nested 'pom.xml' file and 'repo' directory
-	Path pom = dir.resolve("pom.xml");
-	Path repo = dir.resolve("repo");
-
-	/*
-	 * 2) Create test file, and upload to repository
-	 *    (only if repository information is specified)
-	 */
-	String groupId = null;
-	String artifactId = null;
-	String version = null;
-	if (upload)
-	  {
-		groupId = "org.openecomp.policy.audit";
-		artifactId = "repository-audit";
-		version = "0." + System.currentTimeMillis();
-
-		if (repositoryUrl.toLowerCase().contains("snapshot"))
-		  {
-			// use SNAPSHOT version
-			version += "-SNAPSHOT";
-		  }
-
-		// create text file to write
-		FileOutputStream fos =
-		  new FileOutputStream(dir.resolve("repository-audit.txt").toFile());
-		try
-		  {
-			fos.write(version.getBytes());
-		  }
-		finally
-		  {
-			fos.close();
-		  }
-
-		// try to install file in repository
-		if (runProcess
-			(timeoutInSeconds, dir.toFile(), null,
-			 "mvn", "deploy:deploy-file",
-			 "-DrepositoryId=" + repositoryId,
-			 "-Durl=" + repositoryUrl,
-			 "-Dfile=repository-audit.txt",
-			 "-DgroupId=" + groupId,
-			 "-DartifactId=" + artifactId,
-			 "-Dversion=" + version,
-			 "-Dpackaging=txt",
-			 "-DgeneratePom=false") != 0)
-		  {
-			logger.error
-			  ("RepositoryAudit: 'mvn deploy:deploy-file' failed");
-			if (!ignoreErrors)
-			  {
-				response.append("'mvn deploy:deploy-file' failed\n");
-				setResponse(response.toString());
-			  }
-		  }
-		else
-		  {
-			logger.info
-			  ("RepositoryAudit: 'mvn deploy:deploy-file succeeded");
-
-			// we also want to include this new artifact in the download
-			// test (steps 3 and 4)
-			artifacts.add(new Artifact(groupId, artifactId, version, "txt"));
-		  }
-	  }
-
-	/*
-	 * 3) create 'pom.xml' file in temporary directory
-	 */
-	artifacts.add(new Artifact("org.apache.maven/maven-embedder/3.2.2"));
-	
-	StringBuilder sb = new StringBuilder();
-	sb.append
-	  ("<project xmlns=\"http://maven.apache.org/POM/4.0.0\" xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\"\n"
-	   + "         xsi:schemaLocation=\"http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd\">\n"
-	   + "\n"
-	   + "  <modelVersion>4.0.0</modelVersion>\n"
-	   + "  <groupId>empty</groupId>\n"
-	   + "  <artifactId>empty</artifactId>\n"
-	   + "  <version>1.0-SNAPSHOT</version>\n"
-	   + "  <packaging>pom</packaging>\n"
-	   + "\n"
-	   + "  <build>\n"
-	   + "    <plugins>\n"
-	   + "      <plugin>\n"
-	   + "         <groupId>org.apache.maven.plugins</groupId>\n"
-	   + "         <artifactId>maven-dependency-plugin</artifactId>\n"
-	   + "         <version>2.10</version>\n"
-	   + "         <executions>\n"
-	   + "           <execution>\n"
-	   + "             <id>copy</id>\n"
-	   + "             <goals>\n"
-	   + "               <goal>copy</goal>\n"
-	   + "             </goals>\n"
-	   + "             <configuration>\n"
-	   + "               <localRepositoryDirectory>")
-	  .append(repo)
-	  .append("</localRepositoryDirectory>\n")
-	  .append("               <artifactItems>\n");
-	for (Artifact artifact : artifacts)
-	  {
-		// each artifact results in an 'artifactItem' element
-		sb.append
-		  ("                 <artifactItem>\n"
-		   + "                   <groupId>")
-		  .append(artifact.groupId)
-		  .append
-		  ("</groupId>\n"
-		   + "                   <artifactId>")
-		  .append(artifact.artifactId)
-		  .append
-		  ("</artifactId>\n"
-		   + "                   <version>")
-		  .append(artifact.version)
-		  .append
-		  ("</version>\n"
-		   + "                   <type>")
-		  .append(artifact.type)
-		  .append
-		  ("</type>\n"
-		   + "                 </artifactItem>\n");
-	  }
-	sb.append
-	  ("               </artifactItems>\n"
-	   + "             </configuration>\n"
-	   + "           </execution>\n"
-	   + "         </executions>\n"
-	   + "      </plugin>\n"
-	   + "    </plugins>\n"
-	   + "  </build>\n"
-	   + "</project>\n");
-	FileOutputStream fos = new FileOutputStream(pom.toFile());
-	try
-	  {
-		fos.write(sb.toString().getBytes());
-	  }
-	finally
-	  {
-		fos.close();
-	  }
-
-	/*
-	 * 4) Invoke external 'mvn' process to do the downloads
-	 */
-
-	// output file = ${dir}/out (this supports step '4a')
-	File output = dir.resolve("out").toFile();
-
-	// invoke process, and wait for response
-	int rval = runProcess
-	  (timeoutInSeconds, dir.toFile(), output, "mvn", "compile");
-	logger.info("RepositoryAudit: 'mvn' return value = " + rval);
-	if (rval != 0)
-	  {
-		logger.error
-		  ("RepositoryAudit: 'mvn compile' invocation failed");
-		if (!ignoreErrors)
-		  {
-			response.append("'mvn compile' invocation failed\n");
-			setResponse(response.toString());
-		  }
-	  }
-
-	/*
-	 * 4a) Check attempted and successful downloads from output file
-	 *     Note: at present, this step just generates log messages,
-	 *     but doesn't do any verification.
-	 */
-	if (rval == 0)
-	  {
-		// place output in 'fileContents' (replacing the Return characters
-		// with Newline)
-		byte[] outputData = new byte[(int)output.length()];
-		FileInputStream fis = new FileInputStream(output);
-		fis.read(outputData);
-		String fileContents = new String(outputData).replace('\r','\n');
-		fis.close();
-
-		// generate log messages from 'Downloading' and 'Downloaded'
-		// messages within the 'mvn' output
-		int index = 0;
-		while ((index = fileContents.indexOf("\nDown", index)) > 0)
-		  {
-			index += 5;
-			if (fileContents.regionMatches(index, "loading: ", 0, 9))
-			  {
-				index += 9;
-				int endIndex = fileContents.indexOf('\n', index);
-				logger.info
-				  ("RepositoryAudit: Attempted download: '"
-				   + fileContents.substring(index, endIndex) + "'");
-				index = endIndex;
-			  }
-			else if (fileContents.regionMatches(index, "loaded: ", 0, 8))
-			  {
-				index += 8;
-				int endIndex = fileContents.indexOf(' ', index);
-				logger.info
-				  ("RepositoryAudit: Successful download: '"
-				   + fileContents.substring(index, endIndex) + "'");
-				index = endIndex;
-			  }
-		  }
-	  }
-
-	/*
-	 * 5) Check the contents of the directory to make sure the downloads
-	 *    were successful
-	 */
-	for (Artifact artifact : artifacts)
-	  {
-		if (repo.resolve(artifact.groupId.replace('.','/'))
-			.resolve(artifact.artifactId)
-			.resolve(artifact.version)
-			.resolve(artifact.artifactId + "-" + artifact.version + "."
-					 + artifact.type).toFile().exists())
-		  {
-			// artifact exists, as expected
-			logger.info("RepositoryAudit: "
-							  + artifact.toString() + ": exists");
-		  }
-		else
-		  {
-			// Audit ERROR: artifact download failed for some reason
-			logger.error("RepositoryAudit: "
-							   + artifact.toString() + ": does not exist");
-			if (!ignoreErrors)
-			  {
-				response.append("Failed to download artifact: ")
-				  .append(artifact).append('\n');
-				setResponse(response.toString());
-			  }
-		  }
-	  }
-
-	/*
-	 * 6) Use 'curl' to delete the uploaded test file
-	 *    (only if repository information is specified)
-	 */
-	if (upload)
-	  {
-		if (runProcess
-			(timeoutInSeconds, dir.toFile(), null,
-			 "curl",
-			 "--request", "DELETE",
-			 "--user", repositoryUsername + ":" + repositoryPassword,
-			 (repositoryUrl + "/" + groupId.replace('.', '/') + "/" +
-			  artifactId + "/" + version))
-			!= 0)
-		  {
-			logger.error
-			  ("RepositoryAudit: delete of uploaded artifact failed");
-			if (!ignoreErrors)
-			  {
-				response.append("delete of uploaded artifact failed\n");
-				setResponse(response.toString());
-			  }
-		  }
-		else
-		  {
-			logger.info
-			  ("RepositoryAudit: delete of uploaded artifact succeeded");
-			artifacts.add(new Artifact(groupId, artifactId, version, "txt"));
-		  }
-	  }
-
-	/*
-	 * 7) Remove the temporary directory
-	 */
-	Files.walkFileTree
-	  (dir,
-	   new SimpleFileVisitor<Path>()
-	   {
-		 public FileVisitResult visitFile(Path file, BasicFileAttributes attrs)
-		   {
-			 // logger.info("RepositoryAudit: Delete " + file);
-			 file.toFile().delete();
-			 return(FileVisitResult.CONTINUE);
-		   }
-
-		 public FileVisitResult postVisitDirectory(Path file, IOException e)
-		   throws IOException
-		   {
-			 if (e == null)
-			   {
-				 // logger.info("RepositoryAudit: Delete " + file);
-				 file.toFile().delete();
-				 return(FileVisitResult.CONTINUE);
-			   }
-			 else
-			   {
-				 throw(e);
-			   }
-		   }
-	   });
-  }
-
-  /**
-   * Run a process, and wait for the response
-   *
-   * @param timeoutInSeconds the number of seconds to wait for the
-   *	process to terminate
-   * @param directory the execution directory of the process
-   *	(null = current directory)
-   * @param stdout the file to contain the standard output
-   *	(null = discard standard output)
-   * @param command command and arguments
-   * @return the return value of the process
-   * @throws IOException, InterruptedException
-   */
-  static int runProcess(long timeoutInSeconds,
-						File directory, File stdout, String... command)
-	throws IOException, InterruptedException
-  {
-	ProcessBuilder pb = new ProcessBuilder(command);
-	if (directory != null)
-	  {
-		pb.directory(directory);
-	  }
-	if (stdout != null)
-	  {
-		pb.redirectOutput(stdout);
-	  }
-
-	Process process = pb.start();
-	if (process.waitFor(timeoutInSeconds, TimeUnit.SECONDS))
-	  {
-		// process terminated before the timeout
-		return(process.exitValue());
-	  }
-	
-	// process timed out -- kill it, and return -1
-	process.destroyForcibly();
-	return(-1);
-  }
-
-  /* ============================================================ */
-
-  /**
-   * An instance of this class exists for each artifact that we are trying
-   * to download.
-   */
-  static class Artifact
-  {
-	String groupId, artifactId, version, type;
-
-	/**
-	 * Constructor - populate the 'Artifact' instance
-	 *
-	 * @param groupId groupId of artifact
-	 * @param artifactId artifactId of artifact
-	 * @param version version of artifact
-	 * @param type type of the artifact (e.g. "jar")
-	 */
-	Artifact(String groupId, String artifactId, String version, String type)
-	{
-	  this.groupId = groupId;
-	  this.artifactId = artifactId;
-	  this.version = version;
-	  this.type = type;
-	}
-
-	/**
-	 * Constructor - populate an 'Artifact' instance
-	 *
-	 * @param artifact a string of the form:
-	 *		"<groupId>/<artifactId>/<version>[/<type>]"
-	 * @throws IllegalArgumentException if 'artifact' has the incorrect format
-	 */
-	Artifact(String artifact)
-	{
-	  String[] segments = artifact.split("/");
-	  if (segments.length != 4 && segments.length != 3)
-		{
-		  throw(new IllegalArgumentException("groupId/artifactId/version/type"));
-		}
-	  groupId = segments[0];
-	  artifactId = segments[1];
-	  version = segments[2];
-	  type = (segments.length == 4 ? segments[3] : "jar");
-	}
-
-	/**
-	 * @return the artifact id in the form:
-	 *		"<groupId>/<artifactId>/<version>/<type>"
-	 */
-	public String toString()
-	{
-	  return(groupId + "/" + artifactId + "/" + version + "/" + type);
-	}
-  }
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/im/PMStandbyStateChangeNotifier.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/im/PMStandbyStateChangeNotifier.java
deleted file mode 100644
index 30877995..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/im/PMStandbyStateChangeNotifier.java
+++ /dev/null
@@ -1,357 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.im; 
- 
-/* 
- * Per MultiSite_v1-10.ppt:
- * 
- * Extends the StateChangeNotifier class and overwrites the abstract handleStateChange() method to get state changes 
- * and do the following: 
- * 
- * When the Standby Status changes (from providingservice) to hotstandby or coldstandby, 
- * the Active/Standby selection algorithm must stand down if the PDP-D is currently the lead/active node 
- * and allow another PDP-D to take over.  It must also call lock on all engines in the engine management.
- * 
- * When the Standby Status changes from (hotstandby) to coldstandby, the Active/Standby algorithm must NOT assume 
- * the active/lead role.
- *  
- * When the Standby Status changes (from coldstandby or providingservice) to hotstandby, 
- * the Active/Standby algorithm may assume the active/lead role if the active/lead fails.
- * 
- * When the Standby Status changes to providingservice (from hotstandby or coldstandby) call unlock on all 
- * engines in the engine management layer.
- */
-import java.util.Date;
-import java.util.Timer;
-import java.util.TimerTask;
-
-import org.openecomp.policy.common.im.StateChangeNotifier;
-import org.openecomp.policy.common.im.StateManagement;
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-import org.openecomp.policy.drools.core.IntegrityMonitorProperties;
-import org.openecomp.policy.drools.persistence.DroolsPdpsConnector;
-import org.openecomp.policy.drools.persistence.PersistenceFeature;
-import org.openecomp.policy.drools.system.PolicyEngine;
-
-/*
- * Some background:
- * 
- * Originally, there was a "StandbyStateChangeNotifier" that belonged to policy-core, and this class's handleStateChange() method
- * used to take care of invoking conn.standDownPdp().   But testing revealed that when a state change to hot standby occurred 
- * from a demote() operation, first the PMStandbyStateChangeNotifier.handleStateChange() method would be invoked and then the 
- * StandbyStateChangeNotifier.handleStateChange() method would be invoked, and this ordering was creating the following problem:
- * 
- * When PMStandbyStateChangeNotifier.handleStateChange() was invoked it would take a long time to finish, because it would result
- * in SingleThreadedUebTopicSource.stop() being invoked, which can potentially do a 5 second sleep for each controller being stopped.   
- * Meanwhile, as these controller stoppages and their associated sleeps were occurring, the election handler would discover the
- * demoted PDP in hotstandby (but still designated!) and promote it, resulting in the standbyStatus going from hotstandby
- * to providingservice.  So then, by the time that PMStandbyStateChangeNotifier.handleStateChange() finished its work and
- * StandbyStateChangeNotifier.handleStateChange() started executing, the standbyStatus was no longer hotstandby (as effected by
- * the demote), but providingservice (as reset by the election handling logic) and conn.standDownPdp() would not get called!
- * 
- * To fix this bug, we consolidated StandbyStateChangeNotifier and PMStandbyStateChangeNotifier, with the standDownPdp() always 
- * being invoked prior to the TopicEndpoint.manager.lock().  In this way, when the election handling logic is invoked 
- * during the controller stoppages, the PDP is in hotstandby and the standdown occurs.
- * 
- */
-public class PMStandbyStateChangeNotifier extends StateChangeNotifier {
-	// get an instance of logger 
-	private static Logger  logger = FlexLogger.getLogger(PMStandbyStateChangeNotifier.class);
-	private Timer delayActivateTimer;
-	private int pdpUpdateInterval;
-	private boolean isWaitingForActivation;
-	private long startTimeWaitingForActivationMs;
-	private long waitInterval;
-	private boolean isNowActivating;
-	private String previousStandbyStatus;
-	public static String NONE = "none";
-	public static String UNSUPPORTED = "unsupported";
-	public static String HOTSTANDBY_OR_COLDSTANDBY = "hotstandby_or_coldstandby";
-		
-	public PMStandbyStateChangeNotifier(){
-		pdpUpdateInterval = Integer.parseInt(IntegrityMonitorProperties.getProperty(IntegrityMonitorProperties.PDP_UPDATE_INTERVAL));
-		isWaitingForActivation = false;
-		startTimeWaitingForActivationMs = new Date().getTime();
-		//delay the activate so the DesignatedWaiter can run twice - give it an extra 2 seconds
-		waitInterval = 2*pdpUpdateInterval + 2000;
-		isNowActivating=false;
-		previousStandbyStatus = PMStandbyStateChangeNotifier.NONE;
-	}
-
-	@Override
-	public void handleStateChange() {
-		/*
-		 * A note on synchronization: This method is not synchronized because the caller, stateManagememt, 
-		 * has synchronize all of its methods. Only one stateManagement operation can occur at a time. Thus,
-		 * only one handleStateChange() call will ever be made at a time.
-		 */
-		if(logger.isInfoEnabled()){
-			logger.info("handleStateChange: Entering, message='"
-				+ super.getMessage() + "', standbyStatus='"
-				+ super.getStateManagement().getStandbyStatus() + "'");
-		}
-		String standbyStatus = super.getStateManagement().getStandbyStatus();
-		String pdpId = IntegrityMonitorProperties
-				.getProperty(IntegrityMonitorProperties.PDP_INSTANCE_ID);
-		DroolsPdpsConnector conn = PersistenceFeature
-				.getDroolsPdpsConnector("ncompPU");
-
-		if(logger.isDebugEnabled()){
-			logger.debug("handleStateChange: previousStandbyStatus = " + previousStandbyStatus
-				+ "; standbyStatus = " + standbyStatus);
-		}
-		
-		if (standbyStatus == null  || standbyStatus.equals(StateManagement.NULL_VALUE)) {
-			if(logger.isInfoEnabled()){
-				logger.info("handleStateChange: standbyStatus is null; standing down PDP=" + pdpId);
-			}
-			if(previousStandbyStatus.equals(StateManagement.NULL_VALUE)){
-				//We were just here and did this successfully
-				if(logger.isDebugEnabled()){
-					logger.debug("handleStateChange: Is returning because standbyStatus is null and was previously 'null'; PDP=" + pdpId);
-				}
-				return;
-			}
-			isWaitingForActivation = false;
-			try{
-				try{
-					if(logger.isInfoEnabled()){
-						logger.info("handleStateChange: null:  cancelling delayActivationTimer.");
-					}
-					delayActivateTimer.cancel();
-				}catch(Exception e){
-					if(logger.isInfoEnabled()){
-						logger.info("handleStateChange: null no delayActivationTimer existed.");
-					}
-					//If you end of here, there was no active timer
-				}
-				conn.standDownPdp(pdpId);
-				//Only want to lock the endpoints, not the controllers.
-				PolicyEngine.manager.deactivate();
-				//The operation was fully successful, but you cannot assign it a real null value
-				//because later we might try to execute previousStandbyStatus.equals() and get
-				//a null pointer exception.
-				previousStandbyStatus = StateManagement.NULL_VALUE;
-			}catch(Exception e){
-				logger.warn("handleStateChange: standbyStatus == null caught exception: " + e);
-				e.printStackTrace();
-			}
-		} else if (standbyStatus.equals(StateManagement.HOT_STANDBY) || standbyStatus.equals(StateManagement.COLD_STANDBY)) {
-			if(logger.isInfoEnabled()){
-				logger.info("handleStateChange: standbyStatus=" + standbyStatus + "; standing down PDP=" + pdpId);
-			}
-			if(previousStandbyStatus.equals(PMStandbyStateChangeNotifier.HOTSTANDBY_OR_COLDSTANDBY)){
-				//We were just here and did this successfully
-				if(logger.isDebugEnabled()){
-					logger.debug("handleStateChange: Is returning because standbyStatus is "
-						+ standbyStatus + " and was previously " + previousStandbyStatus 
-						+ "; PDP=" + pdpId);
-				}
-				return;
-			}
-			isWaitingForActivation = false;
-			try{
-				try{
-					if(logger.isInfoEnabled()){
-						logger.info("handleStateChange: HOT_STNDBY || COLD_STANDBY:  cancelling delayActivationTimer.");
-					}
-					delayActivateTimer.cancel();
-				}catch(Exception e){
-					if(logger.isInfoEnabled()){
-						logger.info("handleStateChange: HOT_STANDBY || COLD_STANDBY no delayActivationTimer existed.");
-					}
-					//If you end of here, there was no active timer
-				}
-				//Only want to lock the endpoints, not the controllers.
-				conn.standDownPdp(pdpId);
-				PolicyEngine.manager.deactivate();
-				//The operation was fully successful
-				previousStandbyStatus = PMStandbyStateChangeNotifier.HOTSTANDBY_OR_COLDSTANDBY;
-			}catch(Exception e){
-				logger.warn("handleStateChange: standbyStatus == " + standbyStatus + " caught exception: " + e);
-				e.printStackTrace();
-			}
-
-		} else if (standbyStatus.equals(StateManagement.PROVIDING_SERVICE)) {
-			if(logger.isInfoEnabled()){
-				logger.info("handleStateChange: standbyStatus=" + standbyStatus + "; scheduling activation of PDP=" + pdpId);
-			}
-			if(previousStandbyStatus.equals(StateManagement.PROVIDING_SERVICE)){
-				//We were just here and did this successfully
-				if(logger.isDebugEnabled()){
-					logger.debug("handleStateChange: Is returning because standbyStatus is "
-						+ standbyStatus + " and was previously " + previousStandbyStatus 
-						+ "; PDP=" + pdpId);
-				}
-				return;
-			}
-			try{
-				//UnLock all the endpoints
-				if(logger.isInfoEnabled()){
-					logger.info("handleStateChange: standbyStatus=" + standbyStatus + "; controllers must be unlocked.");
-				}
-				/*
-				 * Only endpoints should be unlocked. Controllers have not been locked.
-				 * Because, sometimes, it is possible for more than one PDP-D to become active (race conditions)
-				 * we need to delay the activation of the topic endpoint interfaces to give the election algorithm
-				 * time to resolve the conflict.
-				 */
-				if(logger.isInfoEnabled()){
-					logger.info("handleStateChange: PROVIDING_SERVICE isWaitingForActivation= " +isWaitingForActivation);
-				}
-				//Delay activation for 2*pdpUpdateInterval+2000 ms in case of an election handler conflict.  
-				//You could have multiple election handlers thinking they can take over.
-				
-				 // First let's check that the timer has not died
-				if(isWaitingForActivation){
-					if(logger.isInfoEnabled()){
-						logger.info("handleStateChange: PROVIDING_SERVICE isWaitingForActivation = " + isWaitingForActivation);
-					}
-					long now = new Date().getTime();
-					long waitTimeMs = now - startTimeWaitingForActivationMs;
-					if(waitTimeMs > 3*waitInterval){
-						if(logger.isInfoEnabled()){
-							logger.info("handleStateChange: PROVIDING_SERVICE looks like the activation wait timer may be hung,"
-								+ " waitTimeMs = " + waitTimeMs + " and allowable waitInterval = " + waitInterval
-								+ " Checking whether it is currently in activation. isNowActivating = " + isNowActivating);
-						}
-						//Now check that it is not currently executing an activation
-						if(!isNowActivating){
-							if(logger.isInfoEnabled()){
-								logger.info("handleStateChange: PROVIDING_SERVICE looks like the activation wait timer died");
-							}
-							// This will assure the timer is cancelled and rescheduled.
-							isWaitingForActivation = false;
-						}
-					}
-					
-				}
-				
-				if(!isWaitingForActivation){
-					try{
-						//Just in case there is an old timer hanging around
-						if(logger.isInfoEnabled()){
-							logger.info("handleStateChange: PROVIDING_SERVICE cancelling delayActivationTimer.");
-						}
-						delayActivateTimer.cancel();
-					}catch(Exception e){
-						if(logger.isInfoEnabled()){
-							logger.info("handleStateChange: PROVIDING_SERVICE no delayActivationTimer existed.");
-						}
-						//If you end of here, there was no active timer
-					}
-					delayActivateTimer = new Timer();
-					//delay the activate so the DesignatedWaiter can run twice
-					delayActivateTimer.schedule(new DelayActivateClass(), waitInterval);
-					isWaitingForActivation = true;
-					startTimeWaitingForActivationMs = new Date().getTime();
-					if(logger.isInfoEnabled()){
-						logger.info("handleStateChange: PROVIDING_SERVICE scheduling delayActivationTimer in " + waitInterval + " ms");
-					}
-				}else{
-					if(logger.isInfoEnabled()){
-						logger.info("handleStateChange: PROVIDING_SERVICE delayActivationTimer is waiting for activation.");
-					}
-				}
-				
-			}catch(Exception e){
-				logger.warn("handleStateChange: PROVIDING_SERVICE standbyStatus == providingservice caught exception: " + e);
-				e.printStackTrace();
-			}
-
-		} else {
-			logger.error("handleStateChange: Unsupported standbyStatus=" + standbyStatus + "; standing down PDP=" + pdpId);
-			if(previousStandbyStatus.equals(PMStandbyStateChangeNotifier.UNSUPPORTED)){
-				//We were just here and did this successfully
-				if(logger.isDebugEnabled()){
-					logger.debug("handleStateChange: Is returning because standbyStatus is "
-						+ "UNSUPPORTED and was previously " + previousStandbyStatus 
-						+ "; PDP=" + pdpId);
-				}
-				return;
-			}
-			//Only want to lock the endpoints, not the controllers.
-			isWaitingForActivation = false;
-			try{
-				try{
-					if(logger.isInfoEnabled()){
-						logger.info("handleStateChange: unsupported standbystatus:  cancelling delayActivationTimer.");
-					}
-					delayActivateTimer.cancel();
-				}catch(Exception e){
-					if(logger.isInfoEnabled()){
-						logger.info("handleStateChange: unsupported standbystatus: no delayActivationTimer existed.");
-					}
-					//If you end of here, there was no active timer
-				}
-				conn.standDownPdp(pdpId);
-				PolicyEngine.manager.deactivate();
-				//We know the standbystatus is unsupported
-				previousStandbyStatus = PMStandbyStateChangeNotifier.UNSUPPORTED;
-			}catch(Exception e){
-				logger.warn("handleStateChange: Unsupported standbyStatus == " + standbyStatus + "caught exception: " + e);
-				e.printStackTrace();
-			}
-		}
-		if(logger.isDebugEnabled()){
-			logger.debug("handleStateChange: Exiting");
-		}
-	}
-
-	private class DelayActivateClass extends TimerTask{
-
-		private Object delayActivateLock = new Object();
-
-
-		@Override
-		public void run() {
-			isNowActivating = true;
-			try{
-				if(logger.isInfoEnabled()){
-					logger.info("DelayActivateClass.run: entry");
-				}
-				synchronized(delayActivateLock){
-					PolicyEngine.manager.activate();
-					// The state change fully succeeded
-					previousStandbyStatus = StateManagement.PROVIDING_SERVICE;
-					// We want to set this to false here because the activate call can take a while
-					isWaitingForActivation = false;
-					isNowActivating = false;
-				}
-				if(logger.isInfoEnabled()){
-					logger.info("DelayActivateClass.run.exit");
-				}
-			}catch(Exception e){
-				isWaitingForActivation = false;
-				isNowActivating = false;
-				logger.warn("DelayActivateClass.run: caught an unexpected exception "
-						+ "calling PolicyEngine.manager.activate: " + e);
-				System.out.println(new Date() + " DelayActivateClass.run: caught an unexpected exception");
-				e.printStackTrace();
-			}
-		}
-	}
-	
-	public String getPreviousStandbyStatus(){
-		return previousStandbyStatus;
-	}
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdp.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdp.java
deleted file mode 100644
index 11cc8788..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdp.java
+++ /dev/null
@@ -1,45 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-import java.util.Date;
-import java.util.List;
-
-public interface DroolsPdp {
-
-	public List<DroolsSessionEntity> getSessions();
-	public void addSession(DroolsSession session);
-	public void removeSession(DroolsSession session);
-	public String getPdpId();
-	public boolean isDesignated();
-	public int getPriority();
-	public Date getUpdatedDate();
-	public void setDesignated(boolean isDesignated);
-	public void setUpdatedDate(Date updatedDate);
-	public int comparePriority(DroolsPdp other);
-	public int comparePriority(DroolsPdp other,String previousSite);
-	public DroolsSession getSession(String sessionName);
-	public void setSessionId(String sessionName, long sessionId);
-	public String getSiteName();
-	public void setSiteName(String siteName);
-	public Date getDesignatedDate();
-	public void setDesignatedDate(Date designatedDate);
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpEntity.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpEntity.java
deleted file mode 100644
index 87b58723..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpEntity.java
+++ /dev/null
@@ -1,171 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-import java.io.Serializable;
-import java.util.Date;
-import java.util.List;
-
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.Id;
-import javax.persistence.NamedQueries;
-import javax.persistence.NamedQuery;
-import javax.persistence.OneToMany;
-import javax.persistence.Temporal;
-import javax.persistence.TemporalType;
-
-import org.openecomp.policy.drools.persistence.DroolsPdpObject;
-
-@Entity
-//@Table(name="DroolsPdpEntity")
-
-@NamedQueries({
-	@NamedQuery(name="DroolsPdpEntity.findAll", query="SELECT e FROM DroolsPdpEntity e "),
-	@NamedQuery(name="DroolsPdpEntity.deleteAll", query="DELETE FROM DroolsPdpEntity WHERE 1=1")
-})
-public class DroolsPdpEntity extends DroolsPdpObject implements Serializable{
-
-	private static final long serialVersionUID = 1L;
-	
-	@Id
-	@Column(name="pdpId", nullable=false)
-	private String pdpId="-1";
-	
-	@Column(name="designated", nullable=false)
-	private boolean designated=false;
-	
-	@Column(name="priority", nullable=false)
-	private int priority=0;
-	
-	@Temporal(TemporalType.TIMESTAMP)
-	@Column(name="updatedDate", nullable=false)
-	private Date updatedDate;
-	
-	@Temporal(TemporalType.TIMESTAMP)
-	@Column(name="designatedDate",nullable=false)
-	private Date designatedDate;
-	
-	@Column(name="site", nullable=true, length = 50)
-	private String site;
-	
-	
-	@OneToMany(mappedBy="pdpEntity")
-	//@OneToMany
-	//@JoinColumn(name="pdpId", referencedColumnName="pdpId")
-	//@JoinColumn(name="pdpId")
-	private List<DroolsSessionEntity> sessions;
-	
-	
-	public DroolsPdpEntity(){
-		updatedDate = new Date();
-		//When this is translated to a TimeStamp in MySQL, it assumes the date is relative
-		//to the local timezone.  So, a value of Date(0) is actually Dec 31 18:00:00 CST 1969
-		//which is an invalid value for the MySql TimeStamp 
-		designatedDate = new Date(864000000);
-	}
-
-	@Override
-	public String getPdpId() {
-		return this.pdpId;
-	}
-	
-	public void setPdpId(String pdpId) {
-		this.pdpId = pdpId;
-	}
-	
-	@Override
-	public boolean isDesignated() {
-		return this.designated;
-	}
-
-	@Override
-	public int getPriority() {
-		return this.priority;
-	}
-
-	public void setPriority(int priority) {
-		this.priority = priority;
-	}
-
-	@Override
-	public Date getUpdatedDate() {
-		return this.updatedDate;
-	}
-
-	@Override
-	public void setDesignated(boolean isDesignated) {		
-		this.designated=isDesignated;		
-	}
-
-	@Override
-	public void setUpdatedDate(Date updatedDate) {
-		this.updatedDate=updatedDate;
-	}
-
-	
-	public List<DroolsSessionEntity> getSessions() {
-		return sessions;
-	}
-
-	public void addSession(DroolsSessionEntity session) {
-		sessions.add(session);
-	}
-	
-	public void removeSession(DroolsSessionEntity session) {
-		sessions.remove(session);
-		
-	}
-
-	@Override
-	public void addSession(DroolsSession session) {
-		// TODO Auto-generated method stub
-		
-	}
-
-	@Override
-	public void removeSession(DroolsSession session) {
-		// TODO Auto-generated method stub
-		
-	}
-
-	@Override
-	public String getSiteName() {
-		return site;
-	}
-
-	@Override
-	public void setSiteName(String siteName) {
-		site = siteName;
-		
-	}
-
-	@Override
-	public Date getDesignatedDate() {
-		return designatedDate;
-	}
-
-	@Override
-	public void setDesignatedDate(Date designatedDate) {
-		this.designatedDate = designatedDate;		
-	}
-
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpImpl.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpImpl.java
deleted file mode 100644
index e0f5d816..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpImpl.java
+++ /dev/null
@@ -1,115 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-import java.util.Date;
-import java.util.LinkedList;
-import java.util.List;
-
-
-public class DroolsPdpImpl extends DroolsPdpObject {
-
-	private boolean designated;
-	private int priority;
-	private Date updatedDate;
-	private Date designatedDate;
-	private String pdpId;
-	private String site;
-	private List<DroolsSessionEntity> sessions;
-	
-	public DroolsPdpImpl(String pdpId, boolean designated, int priority, Date updatedDate){
-		this.pdpId = pdpId;
-		this.designated = designated;
-		this.priority = priority;
-		this.updatedDate = updatedDate;
-		//When this is translated to a TimeStamp in MySQL, it assumes the date is relative
-		//to the local timezone.  So, a value of Date(0) is actually Dec 31 18:00:00 CST 1969
-		//which is an invalid value for the MySql TimeStamp 
-		this.designatedDate = new Date(864000000);
-		sessions = new LinkedList<DroolsSessionEntity>();
-
-	}
-	@Override
-	public boolean isDesignated() {
-		
-		return designated;
-	}
-
-	@Override
-	public int getPriority() {		
-		return priority;
-	}
-	@Override
-	public void setUpdatedDate(Date date){
-		this.updatedDate = date;
-	}
-	@Override
-	public Date getUpdatedDate() {		
-		return updatedDate;
-	}
-	
-	@Override
-	public String getPdpId() {		
-		return pdpId;
-	}
-	@Override
-	public void setDesignated(boolean isDesignated) {		
-		this.designated = isDesignated;
-		
-	}
-
-
-	@Override
-	public List<DroolsSessionEntity> getSessions() {
-		// TODO Auto-generated method stub
-		return sessions;
-	}
-	@Override
-	public void addSession(DroolsSession session) {
-		
-		
-	}
-	@Override
-	public void removeSession(DroolsSession session) {
-		// TODO Auto-generated method stub
-		
-	}
-	@Override
-	public String getSiteName() {
-		return site;
-	}
-	@Override
-	public void setSiteName(String siteName) {
-		this.site = siteName;
-		
-	}
-	@Override
-	public Date getDesignatedDate() {
-		return designatedDate;
-	}
-	@Override
-	public void setDesignatedDate(Date designatedDate) {
-		this.designatedDate = designatedDate;
-		
-	}
-
-
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpObject.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpObject.java
deleted file mode 100644
index d9c2d48f..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpObject.java
+++ /dev/null
@@ -1,97 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-
-public abstract class DroolsPdpObject implements DroolsPdp{
-	
-	@Override
-	public boolean equals(Object other){
-		if(other instanceof DroolsPdp){
-		return this.getPdpId().equals(((DroolsPdp)other).getPdpId());
-		}else{
-			return false;
-		}
-	}
-	private int nullSafeCompare(String one, String two){
-		if(one != null && two != null){
-			return one.compareTo(two);
-		}
-		if(one == null && two != null){
-			return -1;
-		}
-		if(one != null && two == null){
-			return 1;
-		}
-		return 0;
-	}
-	@Override
-	public int comparePriority(DroolsPdp other){
-		if(nullSafeCompare(this.getSiteName(),other.getSiteName()) == 0){
-		if(this.getPriority() != other.getPriority()){
-			return this.getPriority() - other.getPriority();
-		}
-		return this.getPdpId().compareTo(other.getPdpId());
-		} else {
-			return nullSafeCompare(this.getSiteName(),other.getSiteName());
-		}
-	}
-	@Override
-	public int comparePriority(DroolsPdp other, String previousSite){
-		if(previousSite == null || previousSite.equals("")){
-			return comparePriority(other);
-		}
-		if(nullSafeCompare(this.getSiteName(),other.getSiteName()) == 0){
-			if(this.getPriority() != other.getPriority()){
-				return this.getPriority() - other.getPriority();
-			}
-			return this.getPdpId().compareTo(other.getPdpId());
-		} else {
-			return nullSafeCompare(this.getSiteName(),other.getSiteName());
-		}
-	}
-	@Override
-	public DroolsSession getSession(String sessionName){
-		for(DroolsSession session : getSessions()){
-			if(session.getSessionName().equals(sessionName)){
-				return session;
-			}
-		}
-		return null;
-	}
-	@Override
-	public void setSessionId(String sessionName, long sessionId){
-		for(DroolsSession session : getSessions()){
-			if(session.getSessionName().equals(sessionName)){
-				session.setSessionId(sessionId);
-				return;
-			}
-		}
-		DroolsSessionEntity newSession = new DroolsSessionEntity();
-		DroolsPdpEntity pdpEntityWithPdpId = new DroolsPdpEntity();
-		pdpEntityWithPdpId.setPdpId(this.getPdpId());
-		newSession.setPdpEntity(pdpEntityWithPdpId);
-		newSession.setPdpId(getPdpId());
-		newSession.setSessionName(sessionName);
-		newSession.setSessionId(sessionId);
-		getSessions().add(newSession);
-	}
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpsConnector.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpsConnector.java
deleted file mode 100644
index fa75c2e7..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpsConnector.java
+++ /dev/null
@@ -1,67 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-import java.util.Collection;
-
-public interface DroolsPdpsConnector {
-
-	
-	//return a list of PDPs, NOT including this PDP
-	public Collection<DroolsPdp> getDroolsPdps();
-	
-	public void update(DroolsPdp pdp);
-	
-	//determines if the DroolsPdp parameter is considered "current" or expired (has it been too long since the Pdp sent an update)
-	public boolean isPdpCurrent(DroolsPdp pdp);
-	
-	// Updates DESIGNATED boolean in PDP record.
-	public void setDesignated(DroolsPdp pdp, boolean designated);
-	
-	// Marks droolspdpentity.DESIGNATED=false, so another PDP-D will go active.
-	public void standDownPdp(String pdpId);
-			
-	// This is used in a JUnit test environment to manually
-	// insert a PDP
-	public void insertPdp(DroolsPdp pdp);
-	
-	// This is used in a JUnit test environment to manually
-	// delete a PDP
-	public void deletePdp(String pdpId);
-		
-	// This is used in a JUnit test environment to manually
-	// clear the droolspdpentity table.
-	public void deleteAllPdps();
-	
-	// This is used in a JUnit test environment to manually
-	// clear the droolspdpentity table.
-	public void deleteAllSessions();
-
-	// This is used in a JUnit test environment to manually
-	// get a PDP
-	public DroolsPdpEntity getPdp(String pdpId);
-	
-	// Used by DroolsPdpsElectionHandler to determine if the currently designated
-	// PDP has failed.
-	public boolean hasDesignatedPdpFailed(Collection<DroolsPdp> pdps);
-
-	
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpsElectionHandler.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpsElectionHandler.java
deleted file mode 100644
index 045c4c25..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPdpsElectionHandler.java
+++ /dev/null
@@ -1,1085 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-import java.util.ArrayList;
-import java.util.Collection;
-import java.util.Date;
-import java.util.LinkedList;
-import java.util.List;
-import java.util.Timer;
-import java.util.TimerTask;
-
-import org.openecomp.policy.common.im.StandbyStatusException;
-import org.openecomp.policy.common.im.StateManagement;
-import org.openecomp.policy.drools.core.DroolsPDPIntegrityMonitor;
-import org.openecomp.policy.drools.core.IntegrityMonitorProperties;
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-import org.openecomp.policy.common.logging.eelf.MessageCodes;
-
-public class DroolsPdpsElectionHandler implements ThreadRunningChecker {
-	// get an instance of logger 
-	private final static Logger  logger = FlexLogger.getLogger(DroolsPdpsElectionHandler.class);	
-	private DroolsPdpsConnector pdpsConnector;
-	private Object pdpsConnectorLock = new Object();
-	private Object checkUpdateWorkerLock = new Object();
-	private Object checkWaitTimerLock = new Object();
-	private Object designationWaiterLock = new Object();
-	
-	/*
-	 * Must be static, so it can be referenced by JpaDroolsPdpsConnector,
-	 * without requiring a reference to the election handler instantiation.
-	 */
-	private static DroolsPdp myPdp;
-	
-	private DesignationWaiter designationWaiter;
-	private Timer updateWorker;
-	private Timer waitTimer;
-	private Date updateWorkerLastRunDate;
-	private Date waitTimerLastRunDate;
-	private int pdpCheckInterval;
-	private int pdpUpdateInterval;
-	private volatile boolean isDesignated;
-	DroolsPDPIntegrityMonitor droolsPdpIntegrityMonitor;
-	StateManagement stateManagement;
-	
-	public DroolsPdpsElectionHandler(DroolsPdpsConnector pdps, DroolsPdp myPdp, DroolsPDPIntegrityMonitor droolsPdpIntegrityMonitor){
-		this.pdpsConnector = pdps;
-		DroolsPdpsElectionHandler.myPdp = myPdp;
-		this.isDesignated = false;
-		this.droolsPdpIntegrityMonitor = droolsPdpIntegrityMonitor;
-		this.stateManagement = droolsPdpIntegrityMonitor.getStateManager();				
-		pdpCheckInterval = 3000;
-		try{
-			pdpCheckInterval = Integer.parseInt(IntegrityMonitorProperties.getProperty(IntegrityMonitorProperties.PDP_CHECK_INVERVAL));
-		}catch(Exception e){
-			logger.error
-			//System.out.println
-			(MessageCodes.EXCEPTION_ERROR ,e, "Could not get pdpCheckInterval property. Using default");
-		}
-		pdpUpdateInterval = 2000;
-		try{
-			pdpUpdateInterval = Integer.parseInt(IntegrityMonitorProperties.getProperty(IntegrityMonitorProperties.PDP_UPDATE_INTERVAL));
-		}catch(Exception e){
-			logger.error
-			//System.out.println
-			(MessageCodes.EXCEPTION_ERROR, e, "Could not get pdpUpdateInterval property. Using default");
-		}	
-		
-		Date now = new Date();
-		
-		// Retrieve the ms since the epoch
-		long nowMs = now.getTime();
-
-		// Create the timer which will update the updateDate in DroolsPdpEntity table.
-		// This is the heartbeat 
-		updateWorker = new Timer();
-		
-		// Schedule the heartbeat to start in 100 ms and run at pdpCheckInterval ms thereafter
-		updateWorker.scheduleAtFixedRate(new TimerUpdateClass(), 100, pdpCheckInterval);
-		updateWorkerLastRunDate = new Date(nowMs + 100);
-		
-		// Create the timer which will run the election algorithm
-		waitTimer = new Timer();
-
-		// Schedule it to start in startMs ms (so it will run after the updateWorker and run at pdpUpdateInterval ms thereafter
-		long startMs = getDWaiterStartMs();
-		designationWaiter = new DesignationWaiter();
-		waitTimer.scheduleAtFixedRate(designationWaiter, startMs, pdpUpdateInterval);
-		waitTimerLastRunDate = new Date(nowMs + startMs);
-	}
-	
-	public List<DroolsSessionEntity> waitForDesignation(){
-		while(isDesignated == false){
-			try {
-				Thread.sleep(1000);
-			} catch (InterruptedException e) {
-				return null;
-			}
-		}
-		return designationWaiter.getSessions();
-
-	}
-	public List<DroolsSessionEntity> getSessions(){
-		return designationWaiter.getSessions();
-	}
-	public void updateMyPdp(){
-		synchronized(pdpsConnectorLock){
-			myPdp.setUpdatedDate(new Date());
-			pdpsConnector.update(myPdp);
-		}
-	}
-	
-	/*
-	 * When the JpaDroolsPdpsConnector.standDown() method is invoked, it needs
-	 * access to myPdp, so it can keep its designation status in sync with the
-	 * DB.
-	 */
-	public static void setMyPdpDesignated(boolean designated) {
-		logger.debug
-		//System.out.println
-			("setMyPdpDesignated: designated=" + designated);
-		myPdp.setDesignated(designated);
-	}
-	
-	private class DesignationWaiter extends TimerTask {
-		// get an instance of logger 
-		private Logger  logger = FlexLogger.getLogger(DesignationWaiter.class);
-		private List<DroolsSessionEntity> sessions = null;
-
-		public List<DroolsSessionEntity> getSessions(){
-			if(sessions != null){
-				return sessions;
-			}
-			return new LinkedList<DroolsSessionEntity>();
-		}
-		public void run() {
-			try{
-				logger.debug
-				//System.out.println
-				("DesignatedWaiter.run: Entering");
-				
-				// just here initially so code still works
-				if (pdpsConnector == null) {
-					waitTimerLastRunDate = new Date();
-					logger.info("DesignatedWaiter.run (pdpsConnector==null) waitTimerLastRunDate = " + waitTimerLastRunDate);
-					
-					return;
-				}
-
-				synchronized (designationWaiterLock) {
-
-					logger.debug
-					//System.out.println
-					("DesignatedWaiter.run: Entering synchronized block");
-
-					checkUpdateWorkerTimer();
-					
-					//It is possible that multiple PDPs are designated lead.  So, we will make a list of all designated
-					//PDPs and then decide which one really should be designated at the end.
-					ArrayList<DroolsPdp> listOfDesignated = new ArrayList<DroolsPdp>();
-
-					Collection<DroolsPdp> pdps = pdpsConnector.getDroolsPdps();
-					DroolsPdp designatedPdp = null;
-
-					logger.debug
-					//System.out.println
-					("DesignatedWaiter.run: pdps.size="
-							+ pdps.size());
-
-					//This is only true if all designated PDPs have failed
-					boolean designatedPdpHasFailed = pdpsConnector.hasDesignatedPdpFailed(pdps);
-					logger.debug
-					//System.out.println
-					("DesignatedWaiter.run: designatedPdpHasFailed="
-							+ designatedPdpHasFailed);
-					for (DroolsPdp pdp : pdps) {
-						logger.debug
-						//System.out.println
-						("DesignatedWaiter.run: evaluating pdp ID: " + pdp.getPdpId());
-
-						/*
-						 * Note: side effect of isPdpCurrent is that any stale but
-						 * designated PDPs will be marked as un-designated.
-						 */
-						boolean isCurrent = pdpsConnector.isPdpCurrent(pdp);
-
-						/*
-						 * We can't use stateManagement.getStandbyStatus() here, because
-						 * we need the standbyStatus, not for this PDP, but for the PDP
-						 * being processed by this loop iteration.
-						 */
-						String standbyStatus = stateManagement.getStandbyStatus(pdp.getPdpId());
-						if(standbyStatus==null){
-							// Treat this case as a cold standby -- if we
-							// abort here, no sessions will be created in a
-							// single-node test environment.
-							standbyStatus = StateManagement.COLD_STANDBY;
-						}
-
-						logger.debug
-						//System.out.println
-						("DesignatedWaiter.run: PDP="
-								+ pdp.getPdpId() + ", isCurrent=" + isCurrent);
-
-						/*
-						 * There are 4 combinations of isDesignated and isCurrent.  We will examine each one in-turn
-						 * and evaluate the each pdp in the list of pdps against each combination.
-						 * 
-						 * This is the first combination of isDesignated and isCurrent
-						 */
-						if (pdp.isDesignated()  &&  isCurrent) { 
-							//It is current, but it could have a standbystatus=coldstandby / hotstandby
-							//If so, we need to stand it down and demote it
-							if(!standbyStatus.equals(StateManagement.PROVIDING_SERVICE)){
-								if(pdp.getPdpId().equals(myPdp.getPdpId())){
-									logger.debug
-									//System.out.println
-									("\n\nDesignatedWaiter.run: myPdp " + myPdp.getPdpId() + " is current and designated, "
-											+ "butstandbystatus is not providingservice. "
-											+ " Executing stateManagement.demote()" + "\n\n");
-									// So, we must demote it
-									try {
-										//Keep the order like this.  StateManagement is last since it triggers controller shutdown
-										//This will change isDesignated and it can enter another if(combination) below
-										pdpsConnector.standDownPdp(pdp.getPdpId()); 
-										myPdp.setDesignated(false);
-										isDesignated = false;
-										if(!(standbyStatus.equals(StateManagement.HOT_STANDBY) || 
-												standbyStatus.equals(StateManagement.COLD_STANDBY))){
-											/*
-											 * Only demote it if it appears it has not already been demoted. Don't worry
-											 * about synching with the topic endpoint states.  That is done by the 
-											 * refreshStateAudit
-											 */
-											stateManagement.demote();
-										}
-										//update the standbystatus to check in a later combination of isDesignated and isCurrent
-										standbyStatus=stateManagement.getStandbyStatus(pdp.getPdpId());
-									} catch (Exception e) {
-										logger.error
-										//System.out.println
-										("DesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + " Caught Exception attempting to demote myPdp'"
-												+ myPdp.getPdpId()
-												+ "', message="
-												+ e.getMessage());
-										System.out.println(new Date() + " DesignatedWaiter.run: caught unexpected exception "
-												+ "from stateManagement.demote()");
-										e.printStackTrace();
-									}
-								}else{
-									// Don't demote a remote PDP that is current.  It should catch itself
-									logger.debug
-									//System.out.println
-									("\n\nDesignatedWaiter.run: myPdp " + myPdp.getPdpId() + " is current and designated, "
-											+ "but standbystatus is not providingservice. "
-											+ " Cannot execute stateManagement.demote() since it it is not myPdp\n\n");
-								}
-
-							}else{
-								// If we get here, it is ok to be on the list
-								logger.debug
-								//System.out.println
-								("DesignatedWaiter.run: PDP="
-										+ pdp.getPdpId()
-										+ " is designated, current and " + standbyStatus +".  Noting PDP as designated.  standbyStatus=" + standbyStatus);
-								listOfDesignated.add(pdp);
-							}
-
-
-						}
-
-
-						/*
-						 * The second combination of isDesignated and isCurrent
-						 * 					
-						 * PDP is designated but not current; it has failed.   So we stand it down (it doesn't matter what
-						 * its standbyStatus is). None of these go on the list.
-						 */
-						if (pdp.isDesignated()  &&  !isCurrent) {
-							logger.info
-							//System.out.println
-							("INFO: DesignatedWaiter.run: PDP="
-									+ pdp.getPdpId()
-									+ " is currently designated but is not current; it has failed.  Standing down.  standbyStatus=" + standbyStatus);
-
-							/*
-							 * Changes designated to 0 but it is still potentially providing service
-							 * Will affect isDesignated, so, it can enter an if(combination) below
-							 */
-							pdpsConnector.standDownPdp(pdp.getPdpId()); 
-
-							//need to change standbystatus to coldstandby
-							if (pdp.getPdpId().equals(myPdp.getPdpId())){
-								logger.debug
-								//System.out.println
-								("\n\nDesignatedWaiter.run: myPdp " + myPdp.getPdpId() + " is not Current. "
-										+ " Executing stateManagement.disableFailed()" + "\n\n");
-								// We found that myPdp is designated but not current
-								// So, we must cause it to disableFail
-								try {
-									myPdp.setDesignated(false);
-									//pdpsConnector.setDesignated(myPdp, false);//not needed?
-									isDesignated = false;
-									stateManagement.disableFailed();
-									//stateManagement.demote();
-								} catch (Exception e) {
-									logger.error
-									//System.out.println
-									("DesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + " Caught Exception attempting to disableFail myPdp'"
-											+ myPdp.getPdpId()
-											+ "', message="
-											+ e.getMessage());
-									System.out.println(new Date() + " DesignatedWaiter.run: caught unexpected exception "
-											+ "from stateManagement.disableFailed()");
-									e.printStackTrace();
-								}
-							} else { //it is a remote PDP that is failed
-								logger.debug
-								//System.out.println
-								("\n\nDesignatedWaiter.run: PDP " + pdp.getPdpId() + " is not Current. "
-										+ " Executing stateManagement.disableFailed(otherResourceName)" + "\n\n");
-								// We found a PDP is designated but not current
-								// We already called standdown(pdp) which will change designated to false
-								// Now we need to disableFail it to get its states in synch.  The standbyStatus
-								// should equal coldstandby
-								try {
-									stateManagement.disableFailed(pdp.getPdpId());
-									//stateManagement.demote(pdp.getPdpId());
-								} catch (Exception e) {
-									logger.error
-									//System.out.println
-									("DesignatedWaiter.run: for PDP" + pdp.getPdpId() 
-											+ " Caught Exception attempting to disableFail(" + pdp.getPdpId() + ")'"
-											+ pdp.getPdpId()
-											+ "', message="
-											+ e.getMessage());
-									System.out.println(new Date() + " DesignatedWaiter.run: caught unexpected exception "
-											+ "from stateManagement.disableFailed()");
-									e.printStackTrace();
-								}
-
-							}
-							continue; //we are not going to do anything else with this pdp
-						} 
-
-						/*
-						 * The third combination of isDesignated and isCurrent
-						 * /*
-						 * If a PDP is not currently designated but is providing service (erroneous, but recoverable) or hot standby 
-						 * we can add it to the list of possible designated if all the designated have failed
-						 */
-						if (!pdp.isDesignated() && isCurrent){
-							if(!(standbyStatus.equals(StateManagement.HOT_STANDBY) ||
-									standbyStatus.equals(StateManagement.COLD_STANDBY))){
-								logger.info("\n\nDesignatedWaiter.run: PDP " + pdp.getPdpId()
-										+ " is NOT designated but IS current and"
-										+ " has a standbystatus=" + standbyStatus);
-								// Since it is current, we assume it can adjust its own state.
-								// We will demote if it is myPdp
-								if(pdp.getPdpId().equals(myPdp.getPdpId())){
-									//demote it
-									logger.info("DesignatedWaiter.run: PDP " + pdp.getPdpId() + " going to "
-											+ "setDesignated = false and calling stateManagement.demote");
-									try {
-										//Keep the order like this.  StateManagement is last since it triggers controller shutdown
-										pdpsConnector.setDesignated(myPdp, false);
-										myPdp.setDesignated(false);
-										isDesignated = false;
-										//This is definitely not a redundant call.  It is attempting to correct a problem
-										stateManagement.demote();
-										//recheck the standbystatus
-										standbyStatus = stateManagement.getStandbyStatus(pdp.getPdpId());
-									} catch (Exception e) {
-										logger.error
-										//System.out.println
-										("DesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + " Caught Exception attempting to demote myPdp'"
-												+ myPdp.getPdpId()
-												+ "', message="
-												+ e.getMessage());
-										System.out.println(new Date() + " DesignatedWaiter.run: caught unexpected exception "
-												+ "from stateManagement.demote()");
-										e.printStackTrace();
-									}
-
-								}
-							}
-							if(standbyStatus.equals(StateManagement.HOT_STANDBY) && designatedPdpHasFailed){
-								//add it to the list
-								logger.info
-								//System.out.println
-								("INFO: DesignatedWaiter.run: PDP=" + pdp.getPdpId()
-										+ " is not designated but is " + standbyStatus + " and designated PDP has failed.  standbyStatus=" 
-										+ standbyStatus);
-								logger.info
-								//System.out.println
-								("DesignatedWaiter.run: Designating PDP=" + pdp.getPdpId());
-								listOfDesignated.add(pdp);
-							}
-							continue; //done with this one
-						}
-
-						/*
-						 * The fourth combination of isDesignated and isCurrent
-						 * 
-						 * We are not going to put any of these on the list since it appears they have failed.
-
-						 * 
-						 */
-						if(!pdp.isDesignated() && !isCurrent) {
-							logger.info
-							//System.out.println
-							("INFO: DesignatedWaiter.run: PDP="
-									+ pdp.getPdpId() + ", designated="
-									+ pdp.isDesignated() + ", current="
-									+ isCurrent
-									+ ", designatedPdpHasFailed="
-									+ designatedPdpHasFailed
-									+ ",  standbyStatus=" + standbyStatus);
-							if(!standbyStatus.equals(StateManagement.COLD_STANDBY)){
-								//stand it down
-								//disableFail it
-								pdpsConnector.standDownPdp(pdp.getPdpId()); 
-								if(pdp.getPdpId().equals(myPdp.getPdpId())){
-									/*
-									 * I don't actually know how this condition could happen, but if it did, we would want
-									 * to declare it failed.
-									 */
-									logger.debug
-									//System.out.println
-									("\n\nDesignatedWaiter.run: myPdp " + myPdp.getPdpId() + " is !current and !designated, "
-											+ " Executing stateManagement.disableFailed()" + "\n\n");
-									// So, we must disableFail it
-									try {
-										//Keep the order like this.  StateManagement is last since it triggers controller shutdown
-										myPdp.setDesignated(false);
-										isDesignated = false;
-										stateManagement.disableFailed();
-										//stateManagement.demote();
-									} catch (Exception e) {
-										logger.error
-										//System.out.println
-										("DesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + " Caught Exception attempting to disableFail myPdp'"
-												+ myPdp.getPdpId()
-												+ "', message="
-												+ e.getMessage());
-										System.out.println(new Date() + " DesignatedWaiter.run: caught unexpected exception "
-												+ "from stateManagement.disableFailed()");
-										e.printStackTrace();
-									}
-								}else{//it is remote
-									logger.debug
-									//System.out.println
-									("\n\nDesignatedWaiter.run: myPdp " + myPdp.getPdpId() + " is !current and !designated, "
-											+ " Executing stateManagement.disableFailed(" + pdp.getPdpId() + ")" + "\n\n");
-									// We already called standdown(pdp) which will change designated to false
-									// Now we need to disableFail it to get its states in sync.  StandbyStatus = coldstandby
-									try {
-										stateManagement.disableFailed(pdp.getPdpId());
-										//stateManagement.demote(pdp.getPdpId());
-									} catch (Exception e) {
-										logger.error
-										//System.out.println
-										("DesignatedWaiter.run: for PDP" + pdp.getPdpId() 
-												+ " Caught Exception attempting to disableFail(" + pdp.getPdpId() + ")'"
-												+ pdp.getPdpId()
-												+ "', message="
-												+ e.getMessage());
-										System.out.println(new Date() + " DesignatedWaiter.run: caught unexpected exception "
-												+ "from stateManagement.disableFailed()");
-										e.printStackTrace();
-									}
-								}
-							}
-						}
-
-
-					} // end pdps loop
-
-					/*
-					 * We have checked the four combinations of isDesignated and isCurrent.  Where appropriate,
-					 * we added the PDPs to the potential list of designated pdps
-					 * 
-					 * We need to give priority to pdps on the same site that is currently being used
-					 * First, however, we must sanitize the list of designated to make sure their are
-					 * only designated members or non-designated members.  There should not be both in 
-					 * the list. Because there are real time delays, it is possible that both types could
-					 * be on the list.
-					 */
-					
-					listOfDesignated = santizeDesignatedList(listOfDesignated);
-
-					/*
-					 * We need to figure out the last pdp that was the primary so we can get the last site 
-					 * name and the last session numbers.  We need to create a "dummy" droolspdp since
-					 * it will be used in later comparrisons and cannot be null.
-					 */
-					
-					DroolsPdp mostRecentPrimary = computeMostRecentPrimary(pdps, listOfDesignated);
-					
-					
-					/*
-					 * It is possible to get here with more than one pdp designated and providingservice. This normally
-					 * occurs when there is a race condition with multiple nodes coming up at the same time. If that is
-					 * the case we must determine which one is the one that should be designated and which one should
-					 * be demoted.
-					 * 
-					 * It is possible to have 0, 1, 2 or more but not all, or all designated.  
-					 *   If we have one designated and current, we chose it and are done
-					 *   If we have 2 or more, but not all, we must determine which one is in the same site as
-					 *   the previously designated pdp.
-					 */
-					
-					designatedPdp = computeDesignatedPdp(listOfDesignated, mostRecentPrimary);
-
-
-					if (designatedPdp == null) {
-						logger.warn
-						//System.out.println
-						("WARNING: DesignatedWaiter.run: No viable PDP found to be Designated. designatedPdp still null.");
-						// Just to be sure the parameters are correctly set
-						myPdp.setDesignated(false);
-						pdpsConnector.setDesignated(myPdp,false);
-						isDesignated = false;
-						
-						waitTimerLastRunDate = new Date();
-						logger.info("DesignatedWaiter.run (designatedPdp == null) waitTimerLastRunDate = " + waitTimerLastRunDate);
-						
-						return;
-						
-					} else if (designatedPdp.getPdpId().equals(myPdp.getPdpId())) {
-						logger.debug
-						//System.out.println
-						("DesignatedWaiter.run: designatedPdp is PDP=" + myPdp.getPdpId());
-						/*
-						 * update function expects myPdp.isDesignated to be true.
-						 */
-						try {
-							//Keep the order like this.  StateManagement is last since it triggers controller init
-							myPdp.setDesignated(true);
-							pdpsConnector.setDesignated(myPdp, true);
-							isDesignated = true;
-							String standbyStatus = stateManagement.getStandbyStatus();
-							if(!standbyStatus.equals(StateManagement.PROVIDING_SERVICE)){
-								/*
-								 * Only call promote if it is not already in the right state.  Don't worry about
-								 * synching the lower level topic endpoint states.  That is done by the
-								 * refreshStateAudit.
-								 * Note that we need to fetch the session list from 'mostRecentPrimary'
-								 * at this point -- soon, 'mostRecentPrimary' will be set to this host.
-								 */
-								this.sessions = mostRecentPrimary.getSessions();
-								stateManagement.promote();
-							}
-						} catch (StandbyStatusException e) {
-							logger.error
-							//System.out.println
-							("ERROR: DesignatedWaiter.run: Caught StandbyStatusException attempting to promote PDP='"
-									+ myPdp.getPdpId()
-									+ "', message="
-									+ e.getMessage());
-							myPdp.setDesignated(false);
-							pdpsConnector.setDesignated(myPdp,false);
-							isDesignated = false;
-							//If you can't promote it, demote it
-							try {
-								String standbyStatus = stateManagement.getStandbyStatus();
-								if(!(standbyStatus.equals(StateManagement.HOT_STANDBY) || 
-										standbyStatus.equals(StateManagement.COLD_STANDBY))){
-									/*
-									 * Only call demote if it is not already in the right state.  Don't worry about
-									 * synching the lower level topic endpoint states.  That is done by the
-									 * refreshStateAudit.
-									 */
-									stateManagement.demote();
-								}
-							} catch (Exception e1) {
-								logger.error
-								//System.out.println
-								("ERROR: DesignatedWaiter.run: Caught StandbyStatusException attempting to promote then demote PDP='"
-										+ myPdp.getPdpId()
-										+ "', message="
-										+ e1.getMessage());
-								System.out.println(new Date() + " DesignatedWaiter.run: caught unexpected exception "
-										+ "from stateManagement.demote()");
-								e1.printStackTrace();
-							}
-
-						} catch (Exception e) {
-							logger.error
-							//System.out.println
-							("ERROR: DesignatedWaiter.run: Caught Exception attempting to promote PDP='"
-									+ myPdp.getPdpId()
-									+ "', message="
-									+ e.getMessage());
-							myPdp.setDesignated(false);
-							pdpsConnector.setDesignated(myPdp,false);
-							isDesignated = false;
-							//If you can't promote it, demote it
-							try {
-								String standbyStatus = stateManagement.getStandbyStatus();
-								if(!(standbyStatus.equals(StateManagement.HOT_STANDBY) || 
-										standbyStatus.equals(StateManagement.COLD_STANDBY))){
-									/*
-									 * Only call demote if it is not already in the right state.  Don't worry about
-									 * synching the lower level topic endpoint states.  That is done by the
-									 * refreshStateAudit.
-									 */
-									stateManagement.demote();
-								}
-							} catch (Exception e1) {
-								logger.error
-								//System.out.println
-								("ERROR: DesignatedWaiter.run: Caught StandbyStatusException attempting to promote then demote PDP='"
-										+ myPdp.getPdpId()
-										+ "', message="
-										+ e1.getMessage());
-								System.out.println(new Date() + " DesignatedWaiter.run: caught unexpected exception "
-										+ "from stateManagement.demote()");
-								e1.printStackTrace();
-							}
-
-						}
-						waitTimerLastRunDate = new Date();
-						logger.info("DesignatedWaiter.run (designatedPdp.getPdpId().equals(myPdp.getPdpId())) waitTimerLastRunDate = " + waitTimerLastRunDate);
-
-						return;
-					}
-					isDesignated = false;
-
-				} // end synchronized
-
-				logger.debug
-				//System.out.println
-				("DesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + "; Returning, isDesignated=" + isDesignated);
-
-				Date tmpDate = new Date();
-				logger.info("DesignatedWaiter.run (end of run) waitTimerLastRunDate = " + tmpDate);
-				
-				waitTimerLastRunDate = tmpDate;
-				
-			}catch(Exception e){
-				logger.error("DesignatedWaiter.run caught an unexpected exception: " + e);
-				System.out.println(new Date() + " DesignatedWaiter.run: caught unexpected exception");
-				e.printStackTrace();
-			}
-		} // end run
-	}
-	
-	public ArrayList<DroolsPdp> santizeDesignatedList(ArrayList<DroolsPdp> listOfDesignated){
-
-		boolean containsDesignated = false;
-		boolean containsHotStandby = false;
-		ArrayList<DroolsPdp> listForRemoval = new ArrayList<DroolsPdp>();
-		for(DroolsPdp pdp : listOfDesignated){
-			logger.debug
-			//System.out.println
-			("DesignatedWaiter.run sanitizing: pdp = " + pdp.getPdpId() 
-					+ " isDesignated = " + pdp.isDesignated());
-			if(pdp.isDesignated()){
-				containsDesignated = true;
-			}else {
-				containsHotStandby = true;
-				listForRemoval.add(pdp);
-			}
-		}
-		if(containsDesignated && containsHotStandby){
-			//remove the hot standby from the list
-			listOfDesignated.removeAll(listForRemoval);
-			containsHotStandby = false;
-		}
-		return listOfDesignated;
-	}
-	
-	public DroolsPdp computeMostRecentPrimary(Collection<DroolsPdp> pdps, ArrayList<DroolsPdp> listOfDesignated){
-		boolean containsDesignated = false;
-		for(DroolsPdp pdp : listOfDesignated){
-			if(pdp.isDesignated()){
-				containsDesignated = true;
-			}
-		}
-		DroolsPdp mostRecentPrimary = new DroolsPdpImpl(null, true, 1, new Date(0));
-		mostRecentPrimary.setSiteName(null);
-		logger.debug
-		//System.out.println
-		("DesignatedWaiter.run listOfDesignated.size() = " + listOfDesignated.size());
-		if(listOfDesignated.size() <=1){
-			logger.debug("DesignatedWainter.run: listOfDesignated.size <=1");
-			//Only one or none is designated or hot standby.  Choose the latest designated date
-			for(DroolsPdp pdp : pdps){
-				logger.debug
-				//System.out.println
-				("DesignatedWaiter.run pdp = " + pdp.getPdpId() 
-						+ " pdp.getDesignatedDate() = "	+ pdp.getDesignatedDate());
-				if(pdp.getDesignatedDate().compareTo(mostRecentPrimary.getDesignatedDate()) > 0){
-					mostRecentPrimary = pdp;
-					logger.debug
-					//System.out.println
-					("DesignatedWaiter.run mostRecentPrimary = " + mostRecentPrimary.getPdpId());
-				}
-			}
-		}else if(listOfDesignated.size() == pdps.size()){
-			logger.debug("DesignatedWainter.run: listOfDesignated.size = pdps.size() which is " + pdps.size());
-			//They are all designated or all hot standby.
-			mostRecentPrimary = null;
-			for(DroolsPdp pdp : pdps){
-				if(mostRecentPrimary == null){
-					mostRecentPrimary = pdp;
-					continue;
-				}
-				if(containsDesignated){ //Choose the site of the first designated date
-					if(pdp.getDesignatedDate().compareTo(mostRecentPrimary.getDesignatedDate()) < 0){
-						mostRecentPrimary = pdp;
-						logger.debug
-						//System.out.println
-						("DesignatedWaiter.run mostRecentPrimary = " + mostRecentPrimary.getPdpId());
-					}
-				}else{ //Choose the site with the latest designated date
-					if(pdp.getDesignatedDate().compareTo(mostRecentPrimary.getDesignatedDate()) > 0){
-						mostRecentPrimary = pdp;
-						logger.debug
-						//System.out.println
-						("DesignatedWaiter.run mostRecentPrimary = " + mostRecentPrimary.getPdpId());
-					}
-				}
-			}
-		}else{
-			logger.debug("DesignatedWainter.run: Some but not all are designated or hot standby. ");
-			//Some but not all are designated or hot standby. 
-			if(containsDesignated){
-				logger.debug("DesignatedWainter.run: containsDesignated = " + containsDesignated);
-				/*
-				 * The list only contains designated.  This is a problem.  It is most likely a race
-				 * condition that resulted in two thinking they should be designated. Choose the 
-				 * site with the latest designated date for the pdp not included on the designated list.
-				 * This should be the site that had the last designation before this race condition
-				 * occurred.
-				 */
-				for(DroolsPdp pdp : pdps){
-					if(listOfDesignated.contains(pdp)){
-						continue; //Don't consider this entry
-					}
-					if(pdp.getDesignatedDate().compareTo(mostRecentPrimary.getDesignatedDate()) > 0){
-						mostRecentPrimary = pdp;
-						logger.debug
-						//System.out.println
-						("DesignatedWaiter.run mostRecentPrimary = " + mostRecentPrimary.getPdpId());
-					}
-				}
-			}else{
-				logger.debug("DesignatedWainter.run: containsDesignated = " + containsDesignated);
-				//The list only contains hot standby. Choose the site of the latest designated date
-				for(DroolsPdp pdp : pdps){
-					if(pdp.getDesignatedDate().compareTo(mostRecentPrimary.getDesignatedDate()) > 0){
-						mostRecentPrimary = pdp;
-						logger.debug
-						//System.out.println
-						("DesignatedWaiter.run mostRecentPrimary = " + mostRecentPrimary.getPdpId());
-					}
-				}
-			}
-		}
-		return mostRecentPrimary;
-	}
-	
-	public DroolsPdp computeDesignatedPdp(ArrayList<DroolsPdp> listOfDesignated, DroolsPdp mostRecentPrimary){
-		DroolsPdp designatedPdp = null;
-		DroolsPdp lowestPriorityPdp = null;
-		if(listOfDesignated.size() > 1){
-			logger.debug
-			//System.out.println
-			("DesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + " listOfDesignated.size():  " + listOfDesignated.size());					
-			DroolsPdp rejectedPdp = null;
-			DroolsPdp lowestPrioritySameSite = null;
-			DroolsPdp lowestPriorityDifferentSite = null;
-			for(DroolsPdp pdp : listOfDesignated){
-				// We need to determine if another PDP is the lowest priority
-				if(nullSafeEquals(pdp.getSiteName(),mostRecentPrimary.getSiteName())){
-					if(lowestPrioritySameSite == null){
-						if(lowestPriorityDifferentSite != null){
-							rejectedPdp = lowestPriorityDifferentSite;
-						}
-						lowestPrioritySameSite = pdp;									
-					}else{
-						if(pdp.getPdpId().equals((lowestPrioritySameSite.getPdpId()))){
-							continue;//nothing to compare
-						}
-						if(pdp.comparePriority(lowestPrioritySameSite) <0){
-							logger.debug
-							//System.out.println
-							("\nDesignatedWaiter.run: myPdp" + myPdp.getPdpId() + " listOfDesignated pdp ID: " + pdp.getPdpId() 
-									+ " has lower priority than pdp ID: " + lowestPrioritySameSite.getPdpId());
-
-							//we need to reject lowestPrioritySameSite
-							rejectedPdp = lowestPrioritySameSite;
-							lowestPrioritySameSite = pdp;
-						} else{
-							//we need to reject pdp and keep lowestPrioritySameSite
-							logger.debug
-							//System.out.println
-							("\nDesignatedWaiter.run: myPdp" + myPdp.getPdpId() + " listOfDesignated pdp ID: " + pdp.getPdpId() 
-									+ " has higher priority than pdp ID: " + lowestPrioritySameSite.getPdpId());
-							rejectedPdp = pdp;
-						}
-					}
-				} else{
-					if(lowestPrioritySameSite != null){
-						//if we already have a candidate for same site, we don't want to bother with different sites
-						rejectedPdp = pdp;
-					} else{
-						if(lowestPriorityDifferentSite == null){
-							lowestPriorityDifferentSite = pdp;
-							continue;
-						}
-						if(pdp.getPdpId().equals((lowestPriorityDifferentSite.getPdpId()))){
-							continue;//nothing to compare
-						}
-						if(pdp.comparePriority(lowestPriorityDifferentSite) <0){
-							logger.debug
-							//System.out.println
-							("\nDesignatedWaiter.run: myPdp" + myPdp.getPdpId() + " listOfDesignated pdp ID: " + pdp.getPdpId() 
-									+ " has lower priority than pdp ID: " + lowestPriorityDifferentSite.getPdpId());
-
-							//we need to reject lowestPriorityDifferentSite
-							rejectedPdp = lowestPriorityDifferentSite;
-							lowestPriorityDifferentSite = pdp;
-						} else{
-							//we need to reject pdp and keep lowestPriorityDifferentSite
-							logger.debug
-							//System.out.println
-							("\nDesignatedWaiter.run: myPdp" + myPdp.getPdpId() + " listOfDesignated pdp ID: " + pdp.getPdpId() 
-									+ " has higher priority than pdp ID: " + lowestPriorityDifferentSite.getPdpId());
-							rejectedPdp = pdp;
-						}
-					}
-				}
-				// If the rejectedPdp is myPdp, we need to stand it down and demote it.  Each pdp is responsible
-				// for demoting itself
-				if(rejectedPdp != null && nullSafeEquals(rejectedPdp.getPdpId(),myPdp.getPdpId())){
-					logger.debug
-					//System.out.println
-					("\n\nDesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + " listOfDesignated myPdp ID: " + myPdp.getPdpId() 
-							+ " is NOT the lowest priority.  Executing stateManagement.demote()" + "\n\n");
-					// We found that myPdp is on the listOfDesignated and it is not the lowest priority
-					// So, we must demote it
-					try {
-						//Keep the order like this.  StateManagement is last since it triggers controller shutdown
-						myPdp.setDesignated(false);
-						pdpsConnector.setDesignated(myPdp, false);
-						isDesignated = false;
-						String standbyStatus = stateManagement.getStandbyStatus();
-						if(!(standbyStatus.equals(StateManagement.HOT_STANDBY) || 
-								standbyStatus.equals(StateManagement.COLD_STANDBY))){
-							/*
-							 * Only call demote if it is not already in the right state.  Don't worry about
-							 * synching the lower level topic endpoint states.  That is done by the
-							 * refreshStateAudit.
-							 */
-							stateManagement.demote();
-						}
-					} catch (Exception e) {
-						myPdp.setDesignated(false);
-						pdpsConnector.setDesignated(myPdp, false);
-						isDesignated = false;
-						logger.error
-						//System.out.println
-						("DesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + " Caught Exception attempting to demote myPdp'"
-								+ myPdp.getPdpId()
-								+ "', message="
-								+ e.getMessage());
-						System.out.println(new Date() + " DesignatedWaiter.run: caught unexpected exception "
-								+ "from stateManagement.demote()");
-						e.printStackTrace();
-					}
-				}
-			} //end: for(DroolsPdp pdp : listOfDesignated)
-			if(lowestPrioritySameSite != null){
-				lowestPriorityPdp = lowestPrioritySameSite;
-			} else {
-				lowestPriorityPdp = lowestPriorityDifferentSite;
-			}
-			//now we have a valid value for lowestPriorityPdp
-			logger.debug
-			//System.out.println
-			("\n\nDesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + " listOfDesignated found the LOWEST priority pdp ID: " 
-					+ lowestPriorityPdp.getPdpId() 
-					+ " It is now the designatedPpd from the perspective of myPdp ID: " + myPdp + "\n\n");
-			designatedPdp = lowestPriorityPdp;
-
-		} else if(listOfDesignated.isEmpty()){
-			logger.debug
-			//System.out.println
-			("\nDesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + " listOfDesignated is: EMPTY.");
-			designatedPdp = null;
-		} else{ //only one in listOfDesignated
-			logger.debug
-			//System.out.println
-			("\nDesignatedWaiter.run: myPdp: " + myPdp.getPdpId() + " listOfDesignated has ONE entry. PDP ID: "
-					+ listOfDesignated.get(0).getPdpId());
-			designatedPdp = listOfDesignated.get(0);
-		}
-		return designatedPdp;
-
-	}
-	
-	private class TimerUpdateClass extends TimerTask{
-
-		@Override
-		public void run() {
-			try{
-				logger.info("TimerUpdateClass.run: entry");
-				checkWaitTimer();
-				synchronized(pdpsConnectorLock){
-					
-					myPdp.setUpdatedDate(new Date());
-					if(myPdp.isDesignated()){
-						myPdp.setDesignatedDate(new Date());
-					}
-					pdpsConnector.update(myPdp);
-					
-					Date tmpDate = new Date();
-					logger.info("TimerUpdateClass.run: updateWorkerLastRunDate = " + tmpDate);
-					
-					updateWorkerLastRunDate = tmpDate;
-				}
-				logger.info("TimerUpdateClass.run.exit");
-			}catch(Exception e){
-				logger.error("TimerUpdateClass.run caught an unexpected exception: " + e);
-				System.out.println(new Date() + " TimerUpdateClass.run caught an unexpected exception");
-				e.printStackTrace();
-			}
-		}
-	}
-	@Override
-	public void checkThreadStatus() {
-		checkUpdateWorkerTimer();
-		checkWaitTimer();
-	}
-
-	private void checkUpdateWorkerTimer(){
-		synchronized(checkUpdateWorkerLock){
-			try{
-				logger.debug("checkUpdateWorkerTimer: entry");
-				Date now = new Date();
-				long nowMs = now.getTime();
-				long updateWorkerMs = updateWorkerLastRunDate.getTime();
-				//give it 2 second cushion
-				if((nowMs - updateWorkerMs)  > pdpCheckInterval + 2000){
-					logger.error("checkUpdateWorkerTimer: nowMs - updateWorkerMs = " + (nowMs - updateWorkerMs) 
-							+ ", exceeds pdpCheckInterval + 2000 = " + (pdpCheckInterval + 2000) + " Will reschedule updateWorker timer");
-
-					try{
-						updateWorker.cancel();
-						// Recalculate the time because this is a synchronized section and the thread could have
-						// been blocked.
-						now = new Date();
-						nowMs = now.getTime();
-						updateWorker = new Timer();
-						// reset the updateWorkerLastRunDate
-						updateWorkerLastRunDate = new Date(nowMs + 100);
-						//execute the first time in 100 ms
-						updateWorker.scheduleAtFixedRate(new TimerUpdateClass(), 100, pdpCheckInterval);
-						logger.info("checkUpdateWorkerTimer: Scheduling updateWorker timer to start in 100 ms ");
-					}catch(Exception e){
-						logger.error("checkUpdateWorkerTimer: Caught unexpected Exception: " + e);
-						System.out.println(new Date() + " checkUpdateWorkerTimer caught an unexpected exception");
-						e.printStackTrace();
-						// Recalculate the time because this is a synchronized section and the thread could have
-						// been blocked.
-						now = new Date();
-						nowMs = now.getTime();
-						updateWorker = new Timer();
-						updateWorkerLastRunDate = new Date(nowMs + 100);
-						updateWorker.scheduleAtFixedRate(new TimerUpdateClass(), 100, pdpCheckInterval);
-						logger.info("checkUpdateWorkerTimer: Attempting to schedule updateWorker timer in 100 ms");
-					}
-
-				}
-				logger.debug("checkUpdateWorkerTimer: exit");
-			}catch(Exception e){
-				logger.error("checkUpdateWorkerTimer: caught unexpected exception: " + e);
-				System.out.println(new Date() + " checkUpdateWorkerTimer - top level - caught an unexpected exception");
-				e.printStackTrace();
-			}
-		}
-	}
-
-	private void checkWaitTimer(){
-		synchronized(checkWaitTimerLock){
-			try{
-				logger.debug("checkWaitTimer: entry");
-				Date now = new Date();
-				long nowMs = now.getTime();
-				long waitTimerMs = waitTimerLastRunDate.getTime();
-
-				//give it 2 times leeway  
-				if((nowMs - waitTimerMs)  > 2*pdpUpdateInterval){
-					logger.error("checkWaitTimer: nowMs - waitTimerMs = " + (nowMs - waitTimerMs) 
-							+ ", exceeds pdpUpdateInterval + 2000 = " + (2*pdpUpdateInterval) + " Will reschedule waitTimer timer");
-
-
-					try{
-						// Recalculate since the thread could have been stalled on the synchronize()
-						nowMs = (new Date()).getTime();
-						// Time to the start of the next pdpUpdateInterval multiple
-						long startMs = getDWaiterStartMs();
-						waitTimer.cancel();
-						designationWaiter = new DesignationWaiter();
-						waitTimer = new Timer();
-						waitTimerLastRunDate = new Date(nowMs + startMs);
-						waitTimer.scheduleAtFixedRate(designationWaiter, startMs, pdpUpdateInterval);
-						logger.info("checkWaitTimer: Scheduling waitTimer timer to start in " + startMs + " ms");
-					}catch(Exception e){
-						logger.error("checkWaitTimer: Caught unexpected Exception: " + e);
-						System.out.println(new Date() + " checkWaitTimer caught an unexpected exception");
-						e.printStackTrace();
-						// Recalculate since the thread could have been stalled on the synchronize()
-						nowMs = (new Date()).getTime();
-						// Time to the start of the next pdpUpdateInterval multiple
-						long startMs = getDWaiterStartMs();
-						designationWaiter = new DesignationWaiter();
-						waitTimer = new Timer();
-						waitTimerLastRunDate = new Date(nowMs + startMs);
-						waitTimer.scheduleAtFixedRate(designationWaiter, startMs, pdpUpdateInterval);
-						logger.info("checkWaitTimer: Scheduling waitTimer timer in " + startMs + " ms");
-					}
-
-				}
-				logger.debug("checkWaitTimer: exit");
-			}catch(Exception e){
-				logger.error("checkWaitTimer: caught unexpected exception: " + e);
-				System.out.println(new Date() + " checkWaitTimer caught an unexpected exception");
-				e.printStackTrace();
-			}
-		}
-	}
-	
-	private long getDWaiterStartMs(){
-		Date now = new Date();
-		
-		// Retrieve the ms since the epoch
-		long nowMs = now.getTime();
-		
-		// Time since the end of the last pdpUpdateInterval multiple
-		long nowModMs = nowMs % pdpUpdateInterval;
-		
-		// Time to the start of the next pdpUpdateInterval multiple
-		long startMs = 2*pdpUpdateInterval - nowModMs;
-
-		// Give the start time a minimum of a 5 second cushion
-		if(startMs < 5000){
-			// Start at the beginning  of following interval
-			startMs = pdpUpdateInterval + startMs;
-		}
-		return startMs;
-	}
-	
-	private boolean nullSafeEquals(Object one, Object two){
-		if(one == null && two == null){
-			return true;
-		}
-		if(one != null && two != null){
-			return one.equals(two);
-		}
-		return false;
-	}
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPersistenceProperties.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPersistenceProperties.java
deleted file mode 100644
index 63af53cb..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsPersistenceProperties.java
+++ /dev/null
@@ -1,64 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-import java.util.Properties;
-
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-
-public class DroolsPersistenceProperties {
-	// get an instance of logger 
-	private static Logger  logger = FlexLogger.getLogger(DroolsPersistenceProperties.class);		
-	/*
-	 * droolsPersistence.properties parameter key values
-	 */
-	public static final String DB_DRIVER = "javax.persistence.jdbc.driver";
-	public static final String DB_DATA_SOURCE  = "hibernate.dataSource";
-	public static final String DB_URL = "javax.persistence.jdbc.url";
-	public static final String DB_USER = "javax.persistence.jdbc.user";
-	public static final String DB_PWD = "javax.persistence.jdbc.password";
-			
-	private static Properties properties = null;
-	/*
-	 * Initialize the parameter values from the droolsPersitence.properties file values
-	 * 
-	 * This is designed so that the Properties object is obtained from the droolsPersistence.properties
-	 * file and then is passed to this method to initialize the value of the parameters.
-	 * This allows the flexibility of JUnit tests using getProperties(filename) to get the
-	 * properties while runtime methods can use getPropertiesFromClassPath(filename).
-	 * 
-	 */
-	public static void initProperties (Properties prop){
-		logger.info("DroolsPersistenceProperties.initProperties(Properties): entry");
-		logger.info("\n\nDroolsPersistenceProperties.initProperties: Properties = \n" + prop + "\n\n");
-		
-		properties = prop;
-	}
-
-	public static String getProperty(String key){
-		return properties.getProperty(key);
-	}
-	
-	public static Properties getProperties() {
-		return properties;
-	}
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsSession.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsSession.java
deleted file mode 100644
index 21a480d9..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsSession.java
+++ /dev/null
@@ -1,31 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-public interface DroolsSession {
-
-	public String getPdpId();
-	public void setPdpId(String pdpId);
-	public String getSessionName();
-	public void setSessionName(String sessionName);
-	public long getSessionId();
-	public void setSessionId(long sessionId);
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsSessionEntity.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsSessionEntity.java
deleted file mode 100644
index 247f9c81..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/DroolsSessionEntity.java
+++ /dev/null
@@ -1,93 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-import java.io.Serializable;
-
-import javax.persistence.Column;
-import javax.persistence.Entity;
-import javax.persistence.Id;
-import javax.persistence.ManyToOne;
-@Entity
-public class DroolsSessionEntity implements Serializable, DroolsSession {
-
-	private static final long serialVersionUID = -5495057038819948709L;
-	
-	@Id
-	@Column(name="pdpId", nullable=false)
-	private String pdpId="-1";
-	@Id
-	@Column(name="sessionName", nullable=false)
-	private String sessionName="-1";
-	
-	@Column(name="sessionId", nullable=false)
-	private long sessionId=-1L;
-
-	@ManyToOne
-	private DroolsPdpEntity pdpEntity;
-	public DroolsSessionEntity(){
-		
-	}
-	@Override
-	public String getPdpId() {
-		return pdpId;
-	}
-	@Override
-	public void setPdpId(String pdpId) {
-		this.pdpId = pdpId;
-	}
-	@Override
-	public String getSessionName() {
-		return sessionName;
-	}
-	@Override
-	public void setSessionName(String sessionName) {
-		this.sessionName = sessionName;
-	}
-	@Override
-	public long getSessionId() {
-		return sessionId;
-	}
-
-	@Override
-	public void setSessionId(long sessionId) {
-		this.sessionId = sessionId;
-	}
-	public void setPdpEntity(DroolsPdpEntity pdpEntity){
-		this.pdpEntity = pdpEntity;
-	}
-	@Override
-	public boolean equals(Object other){
-		if(other instanceof DroolsSession){
-		return this.getPdpId().equals(((DroolsSession)other).getPdpId()) && this.getSessionName().equals(((DroolsSession)other).getSessionName());
-		}else{
-			return false;
-		}
-	}
-	
-	@Override
-	public int hashCode(){
-		String combinedId = this.getPdpId().concat(":").concat(this.getSessionName());
-		return combinedId.hashCode();
-	}
-
-
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/JpaDroolsPdpsConnector.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/JpaDroolsPdpsConnector.java
deleted file mode 100644
index d2032895..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/JpaDroolsPdpsConnector.java
+++ /dev/null
@@ -1,689 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-import java.util.Collection;
-import java.util.Date;
-import java.util.LinkedList;
-import java.util.List;
-
-import javax.persistence.EntityManager;
-import javax.persistence.EntityManagerFactory;
-import javax.persistence.FlushModeType;
-import javax.persistence.LockModeType;
-import javax.persistence.Query;
-
-import org.openecomp.policy.drools.core.IntegrityMonitorProperties;
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-import org.openecomp.policy.common.logging.eelf.MessageCodes;
-
-
-public class JpaDroolsPdpsConnector implements DroolsPdpsConnector {
-
-	// get an instance of logger 
-	private static Logger  logger = FlexLogger.getLogger(JpaDroolsPdpsConnector.class);
-	private EntityManagerFactory emf;
-		
-	
-	//not sure if we want to use the same entity manager factory for drools session and pass it in here, or create a new one
-	public JpaDroolsPdpsConnector(EntityManagerFactory emf){
-		this.emf = emf;		
-	}
-	@Override
-	public Collection<DroolsPdp> getDroolsPdps() {
-		//return a list of all the DroolsPdps in the database
-		EntityManager em = emf.createEntityManager();
-		try {
-			em.getTransaction().begin();
-			Query droolsPdpsListQuery = em.createQuery("SELECT p FROM DroolsPdpEntity p");
-			List<?> droolsPdpsList = droolsPdpsListQuery.setLockMode(LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList();
-			LinkedList<DroolsPdp> droolsPdpsReturnList = new LinkedList<DroolsPdp>();
-			for(Object o : droolsPdpsList){
-				if(o instanceof DroolsPdp){
-					//Make sure it is not a cached version
-					em.refresh((DroolsPdpEntity)o);
-					droolsPdpsReturnList.add((DroolsPdp)o);
-					if (logger.isDebugEnabled()) {
-						DroolsPdp droolsPdp = (DroolsPdp)o;
-						logger.debug("getDroolsPdps: PDP=" + droolsPdp.getPdpId()
-								+ ", isDesignated=" + droolsPdp.isDesignated()
-								+ ", updatedDate=" + droolsPdp.getUpdatedDate()
-								+ ", priority=" + droolsPdp.getPriority());
-					}
-				}
-			}
-			try{
-			em.getTransaction().commit();
-			}catch(Exception e){
-				  logger.error
-					(MessageCodes.EXCEPTION_ERROR, e,"Cannot commit getDroolsPdps() transaction");
-			}
-			return droolsPdpsReturnList;
-		} finally {
-			cleanup(em, "getDroolsPdps");
-		}
-	}
-
-	private boolean nullSafeEquals(Object one, Object two){
-		if(one == null && two == null){
-			return true;
-		}
-		if(one != null && two != null){
-			return one.equals(two);
-		}
-		return false;
-	}
-	
-	@Override
-	public void update(DroolsPdp pdp) {
-		
-		if (logger.isDebugEnabled()) {
-			logger.debug("update: Entering, pdpId=" + pdp.getPdpId());
-		}
-		
-		//this is to update our own pdp in the database
-		EntityManager em = emf.createEntityManager();
-		try {
-			em.getTransaction().begin();
-			Query droolsPdpsListQuery = em.createQuery("SELECT p FROM DroolsPdpEntity p WHERE p.pdpId=:pdpId");
-			droolsPdpsListQuery.setParameter("pdpId", pdp.getPdpId());
-			List<?> droolsPdpsList = droolsPdpsListQuery.setLockMode(LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList();
-			//em.getTransaction().begin();
-			DroolsPdpEntity droolsPdpEntity;
-			if(droolsPdpsList.size() == 1 && (droolsPdpsList.get(0) instanceof DroolsPdpEntity)){						
-				droolsPdpEntity = (DroolsPdpEntity)droolsPdpsList.get(0);			
-				//if(pdp.getSessionId() < 0){
-					//if its less than 0, then we know it is not a real session number so we want to save the one that the database has for us, to avoid information loss
-					//pdp.setSessionId(droolsPdpEntity.getSessionId());
-				//}
-				Date currentDate = new Date();
-				long difference = currentDate.getTime()-droolsPdpEntity.getUpdatedDate().getTime();
-				//just set some kind of default here
-				long pdpTimeout = 15000;
-				try{
-					pdpTimeout = Long.parseLong(IntegrityMonitorProperties.getProperty(IntegrityMonitorProperties.PDP_TIMEOUT));
-				}catch(Exception e){
-					  logger.error
-						(MessageCodes.EXCEPTION_ERROR, e,"Could not get PDP timeout property, using default.");
-				}
-				boolean isCurrent = difference<pdpTimeout;
-				if (logger.isDebugEnabled()) {
-					logger.debug("update: PDP=" + pdp.getPdpId() + ", isCurrent="
-							+ isCurrent + ", difference=" + difference
-							+ ", pdpTimeout=" + pdpTimeout + ", designated="
-							+ droolsPdpEntity.isDesignated());
-				}
-			} else {
-				if (logger.isDebugEnabled()) {
-					logger.debug("update: For PDP=" + pdp.getPdpId()
-							+ ", instantiating new DroolsPdpEntity");
-				}
-				droolsPdpEntity = new DroolsPdpEntity();
-				em.persist(droolsPdpEntity);
-				droolsPdpEntity.setPdpId(pdp.getPdpId());				
-			}
-			if(droolsPdpEntity.getPriority() != pdp.getPriority()){
-				droolsPdpEntity.setPriority(pdp.getPriority());
-			}
-			if(!droolsPdpEntity.getUpdatedDate().equals(pdp.getUpdatedDate())){
-				droolsPdpEntity.setUpdatedDate(pdp.getUpdatedDate());
-			}
-			if(!droolsPdpEntity.getDesignatedDate().equals(pdp.getDesignatedDate())){
-				droolsPdpEntity.setDesignatedDate(pdp.getDesignatedDate());
-			}
-			if(!nullSafeEquals(droolsPdpEntity.getSiteName(),pdp.getSiteName())){
-				droolsPdpEntity.setSiteName(pdp.getSiteName());
-			}
-			List<DroolsSessionEntity> sessionsToAdd = new LinkedList<DroolsSessionEntity>();
-			for(DroolsSessionEntity localSession : pdp.getSessions()){
-				boolean found = false;
-				for(DroolsSessionEntity dbSession : droolsPdpEntity.getSessions()){
-					if(localSession.equals(dbSession)){
-						found = true;
-						dbSession.setSessionId(localSession.getSessionId());
-					}
-				}
-				if(!found){
-					sessionsToAdd.add(localSession);
-				}
-
-			}
-			for(DroolsSessionEntity sessionToAdd : sessionsToAdd){
-				em.persist(sessionToAdd);
-				droolsPdpEntity.getSessions().add(sessionToAdd);
-			}		
-
-			
-			if(droolsPdpEntity.isDesignated() != pdp.isDesignated()){
-				if (logger.isDebugEnabled()) {
-					logger.debug("update: pdpId=" + pdp.getPdpId()
-							+ ", pdp.isDesignated=" + pdp.isDesignated()
-							+ ", droolsPdpEntity.pdpId="
-							+ droolsPdpEntity.getPdpId()
-							+ ", droolsPdpEntity.isDesignated="
-							+ droolsPdpEntity.isDesignated());
-				}
-				droolsPdpEntity.setDesignated(pdp.isDesignated());
-			}
-			em.getTransaction().commit();
-		} finally {
-			cleanup(em, "update");
-		}
-		
-		if (logger.isDebugEnabled()) {
-			logger.debug("update: Exiting");
-		}
-
-	}
-
-	/*
-	 * Note: A side effect of this boolean method is that if the PDP is designated but not current, the 
-	 * droolspdpentity.DESIGNATED column will be set to false (the PDP will be un-designated, i.e. marked as
-	 * being in standby mode)
-	 */
-	@Override
-	public boolean isPdpCurrent(DroolsPdp pdp) {
-		
-		boolean isCurrent = isCurrent(pdp);
-		
-		EntityManager em = emf.createEntityManager();
-		try{
-		if(!isCurrent && pdp.isDesignated()){
-			em.getTransaction().begin();
-			Query droolsPdpsListQuery = em.createQuery("SELECT p FROM DroolsPdpEntity p WHERE p.pdpId=:pdpId");
-			droolsPdpsListQuery.setParameter("pdpId", pdp.getPdpId());
-			List<?> droolsPdpsList = droolsPdpsListQuery.setLockMode(LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList();
-			if(droolsPdpsList.size() == 1 && droolsPdpsList.get(0) instanceof DroolsPdpEntity){			
-				if (logger.isDebugEnabled()) {
-					logger.debug("isPdpCurrent: PDP=" + pdp.getPdpId() + " designated but not current; setting designated to false");
-				}
-				DroolsPdpEntity droolsPdpEntity = (DroolsPdpEntity)droolsPdpsList.get(0);
-				droolsPdpEntity.setDesignated(false);
-				em.getTransaction().commit();
-			} else {
-				logger.warn("isPdpCurrent: PDP=" + pdp.getPdpId() + " is designated but not current; however it does not have a DB entry, so cannot set DESIGNATED to false!");
-			}
-		} else {
-			if (logger.isDebugEnabled()) {
-				logger.debug("isPdpCurrent: For PDP=" + pdp.getPdpId()
-						+ ", designated="
-						+ pdp.isDesignated() + ", isCurrent=" + isCurrent);
-			}
-		}
-		}catch(Exception e){
-			  logger.error
-				(MessageCodes.EXCEPTION_ERROR, e,"Could not update expired record marked as designated in the database");
-		} finally {
-			cleanup(em, "isPdpCurrent");
-		}
-		return isCurrent;
-		
-	}
-	
-	@Override
-	public void setDesignated(DroolsPdp pdp, boolean designated) {
-
-		if (logger.isDebugEnabled()) {
-			logger.debug("setDesignated: Entering, pdpId='" + pdp.getPdpId()
-					+ "', designated=" + designated);
-		}
-
-		EntityManager em = null;
-		try {
-			em = emf.createEntityManager();
-			em.getTransaction().begin();
-			Query droolsPdpsListQuery = em
-					.createQuery("SELECT p FROM DroolsPdpEntity p WHERE p.pdpId=:pdpId");
-			droolsPdpsListQuery.setParameter("pdpId", pdp.getPdpId());
-			List<?> droolsPdpsList = droolsPdpsListQuery.setLockMode(
-					LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList();
-			if (droolsPdpsList.size() == 1
-					&& droolsPdpsList.get(0) instanceof DroolsPdpEntity) {
-				DroolsPdpEntity droolsPdpEntity = (DroolsPdpEntity) droolsPdpsList
-						.get(0);
-				if (logger.isDebugEnabled()) {
-					logger.debug("setDesignated: PDP=" + pdp.getPdpId()
-							+ " found, designated="
-							+ droolsPdpEntity.isDesignated() + ", setting to "
-							+ designated);
-				}
-				droolsPdpEntity.setDesignated(designated);
-				em.getTransaction().commit();
-			} else {
-				logger.error("setDesignated: PDP=" + pdp.getPdpId()
-						+ " not in DB; cannot update designation");
-			}
-		} catch (Exception e) {
-			logger.error("setDesignated: Caught Exception, message='"
-					+ e.getMessage() + "'");
-		} finally {
-			cleanup(em, "setDesignated");
-		}
-
-		if (logger.isDebugEnabled()) {
-			logger.debug("setDesignated: Exiting");
-		}
-
-	}
-	
-	
-	@Override
-	public void standDownPdp(String pdpId) {
-		
-		logger.info("standDownPdp: Entering, pdpId='" + pdpId + "'");
-
-		EntityManager em = null;
-		try {
-			/*
-			 * Start transaction.
-			 */
-			em = emf.createEntityManager();
-			em.getTransaction().begin();
-
-			/*
-			 * Get droolspdpentity record for this PDP and mark DESIGNATED as
-			 * false.
-			 */
-			Query droolsPdpsListQuery = em
-					.createQuery("SELECT p FROM DroolsPdpEntity p WHERE p.pdpId=:pdpId");
-			droolsPdpsListQuery.setParameter("pdpId", pdpId);
-			List<?> droolsPdpsList = droolsPdpsListQuery.setLockMode(
-					LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList();
-			DroolsPdpEntity droolsPdpEntity;
-			if (droolsPdpsList.size() == 1
-					&& (droolsPdpsList.get(0) instanceof DroolsPdpEntity)) {
-				droolsPdpEntity = (DroolsPdpEntity) droolsPdpsList.get(0);
-				droolsPdpEntity.setDesignated(false);
-				em.persist(droolsPdpEntity);
-				logger.info("standDownPdp: PDP=" + pdpId + " persisted as non-designated.");
-			} else {
-				logger.error("standDownPdp: Missing record in droolspdpentity for pdpId="
-						+ pdpId + "; cannot stand down PDP");
-			}
-
-			/*
-			 * End transaction.
-			 */
-			em.getTransaction().commit();
-			cleanup(em, "standDownPdp");
-			em = null;
-			
-			// Keep the election handler in sync with the DB
-			DroolsPdpsElectionHandler.setMyPdpDesignated(false);
-
-		} catch (Exception e) {
-			logger.error("standDownPdp: Unexpected Exception attempting to mark DESIGNATED as false for droolspdpentity, pdpId="
-					+ pdpId
-					+ ".  Cannot stand down PDP; message="
-					+ e.getMessage());
-		} finally {
-			cleanup(em, "standDownPdp");
-		}
-		
-		logger.info("standDownPdp: Exiting");
-
-	}
-	
-	/*
-	 * Determines whether or not a designated PDP has failed.
-	 * 
-	 * Note: The update method, which is run periodically by the
-	 * TimerUpdateClass, will un-designate a PDP that is stale.
-	 */
-	@Override
-	public boolean hasDesignatedPdpFailed(Collection<DroolsPdp> pdps) {
-
-		if (logger.isDebugEnabled()) {
-			logger.debug("hasDesignatedPdpFailed: Entering, pdps.size()="
-					+ pdps.size());
-		}
-
-		boolean failed = true;
-		boolean foundDesignatedPdp = false;
-
-		for (DroolsPdp pdp : pdps) {
-
-			/*
-			 * Normally, the update method will un-designate any stale PDP, but
-			 * we check here to see if the PDP has gone stale since the update
-			 * method was run.
-			 * 
-			 * Even if we determine that the designated PDP is current, we keep
-			 * going (we don't break), so we can get visibility into the other
-			 * PDPs, when in DEBUG mode.
-			 */
-			if (pdp.isDesignated() && isCurrent(pdp)) {
-				if (logger.isDebugEnabled()) {
-					logger.debug("hasDesignatedPdpFailed: Designated PDP="
-							+ pdp.getPdpId() + " is current");
-				}
-				failed = false;
-				foundDesignatedPdp = true;
-			} else if (pdp.isDesignated() && !isCurrent(pdp)) {
-				logger.error("hasDesignatedPdpFailed: Designated PDP="
-						+ pdp.getPdpId() + " has failed");
-				foundDesignatedPdp = true;
-			} else {
-				if (logger.isDebugEnabled()) {
-					logger.debug("hasDesignatedPdpFailed: PDP="
-							+ pdp.getPdpId() + " is not designated");
-				}
-			}
-		}
-
-		if (logger.isDebugEnabled()) {
-			logger.debug("hasDesignatedPdpFailed: Exiting and returning, foundDesignatedPdp="
-					+ foundDesignatedPdp);
-		}
-		return failed;
-	}
-	
-	
-	private boolean isCurrent(DroolsPdp pdp) {
-	
-		if (logger.isDebugEnabled()) {
-			logger.debug("isCurrent: Entering, pdpId="
-					+ pdp.getPdpId());
-		}
-	
-		boolean current = false;
-	
-		// Return if the current PDP is considered "current" based on whatever
-		// time box that may be.
-		// If the the PDP is not current, we should mark it as not primary in
-		// the database
-		Date currentDate = new Date();
-		long difference = currentDate.getTime()
-				- pdp.getUpdatedDate().getTime();
-		// just set some kind of default here
-		long pdpTimeout = 15000;
-		try {
-			pdpTimeout = Long.parseLong(IntegrityMonitorProperties
-					.getProperty(IntegrityMonitorProperties.PDP_TIMEOUT));
-			if (logger.isDebugEnabled()) {
-				logger.debug("isCurrent: pdp.timeout=" + pdpTimeout);
-			}		
-		} catch (Exception e) {
-			  logger.error
-				(MessageCodes.EXCEPTION_ERROR, e,
-					"isCurrent: Could not get PDP timeout property, using default.");
-		}
-		current = difference < pdpTimeout;
-	
-		if (logger.isDebugEnabled()) {
-			logger.debug("isCurrent: Exiting, difference="
-					+ difference + ", pdpTimeout=" + pdpTimeout
-					+ "; returning current=" + current);
-		}
-	
-		return current;
-	}
-	
-	
-	/*
-	 * Currently this method is only used in a JUnit test environment. Gets a
-	 * PDP record from droolspdpentity table.
-	 */
-	@Override
-	public DroolsPdpEntity getPdp(String pdpId) {
-	
-		if (logger.isDebugEnabled()) {
-			logger.debug("getPdp: Entering and getting PDP with pdpId='" + pdpId
-					+ "'");
-		}
-	
-		DroolsPdpEntity droolsPdpEntity = null;
-	
-		EntityManager em = null;
-		try {
-			em = emf.createEntityManager();
-			em.getTransaction().begin();
-			Query droolsPdpsListQuery = em
-					.createQuery("SELECT p FROM DroolsPdpEntity p WHERE p.pdpId=:pdpId");
-			droolsPdpsListQuery.setParameter("pdpId", pdpId);
-			List<?> droolsPdpsList = droolsPdpsListQuery.setLockMode(
-					LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList();
-			if (droolsPdpsList.size() == 1
-					&& droolsPdpsList.get(0) instanceof DroolsPdpEntity) {
-				droolsPdpEntity = (DroolsPdpEntity) droolsPdpsList.get(0);
-				if (logger.isDebugEnabled()) {
-					logger.debug("getPdp: PDP=" + pdpId
-							+ " found, isDesignated="
-							+ droolsPdpEntity.isDesignated() + ", updatedDate="
-							+ droolsPdpEntity.getUpdatedDate() + ", priority="
-							+ droolsPdpEntity.getPriority());							
-				}
-				
-				// Make sure the droolsPdpEntity is not a cached version
-				em.refresh(droolsPdpEntity);
-				
-				em.getTransaction().commit();
-			} else {
-				logger.error("getPdp: PDP=" + pdpId + " not found!?");
-			}
-		} catch (Exception e) {
-			  logger.error
-				(MessageCodes.EXCEPTION_ERROR, e,"getPdp: Caught Exception attempting to get PDP, message='"
-					+ e.getMessage() + "'");
-		} finally {
-			cleanup(em, "getPdp");
-		}
-	
-		if (logger.isDebugEnabled()) {
-			logger.debug("getPdp: Returning droolsPdpEntity=" + droolsPdpEntity);
-		}
-		return droolsPdpEntity;
-	
-	}
-	
-	/*
-	 * Normally this method should only be used in a JUnit test environment.
-	 * Manually inserts a PDP record in droolspdpentity table.
-	 */
-	@Override
-	public void insertPdp(DroolsPdp pdp) {
-
-		logger.info("insertPdp: Entering and manually inserting PDP");
-
-		/*
-		 * Start transaction
-		 */
-		EntityManager em = emf.createEntityManager();
-		try {
-			em.getTransaction().begin();
-
-			/*
-			 * Insert record.
-			 */
-			DroolsPdpEntity droolsPdpEntity = new DroolsPdpEntity();
-			em.persist(droolsPdpEntity);
-			droolsPdpEntity.setPdpId(pdp.getPdpId());
-			droolsPdpEntity.setDesignated(pdp.isDesignated());
-			droolsPdpEntity.setPriority(pdp.getPriority());
-			droolsPdpEntity.setUpdatedDate(pdp.getUpdatedDate());
-			droolsPdpEntity.setSiteName(pdp.getSiteName());
-
-			/*
-			 * End transaction.
-			 */
-			em.getTransaction().commit();
-		} finally {
-			cleanup(em, "insertPdp");
-		}
-
-		logger.info("insertPdp: Exiting");
-
-	}
-	
-	/*
-	 * Normally this method should only be used in a JUnit test environment.
-	 * Manually deletes all PDP records in droolspdpentity table.
-	 */
-	@Override
-	public void deleteAllPdps() {
-	
-		logger.info("deleteAllPdps: Entering");
-	
-		/*
-		 * Start transaction
-		 */
-		EntityManager em = emf.createEntityManager();
-		try {
-			em.getTransaction().begin();
-	
-			Query droolsPdpsListQuery = em
-					.createQuery("SELECT p FROM DroolsPdpEntity p");
-			@SuppressWarnings("unchecked")
-			List<DroolsPdp> droolsPdpsList = droolsPdpsListQuery.setLockMode(
-					LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList();
-			logger.info("deleteAllPdps: Deleting " + droolsPdpsList.size() + " PDPs");
-			for (DroolsPdp droolsPdp : droolsPdpsList) {
-				String pdpId = droolsPdp.getPdpId();
-				deletePdp(pdpId);
-			}
-	
-			/*
-			 * End transaction.
-			 */
-			em.getTransaction().commit();
-		} finally {
-			cleanup(em, "deleteAllPdps");
-		}
-		
-		logger.info("deleteAllPdps: Exiting");
-	
-	}
-	
-	/*
-	 * Normally this method should only be used in a JUnit test environment.
-	 * Manually deletes a PDP record in droolspdpentity table.
-	 */
-	@Override
-	public void deletePdp(String pdpId) {
-	
-		logger.info("deletePdp: Entering and manually deleting pdpId='" + pdpId
-				+ "'");
-	
-		/*
-		 * Start transaction
-		 */
-		EntityManager em = emf.createEntityManager();
-		try {
-			em.getTransaction().begin();
-		
-			/*
-			 * Delete record.
-			 */
-			DroolsPdpEntity droolsPdpEntity = em.find(DroolsPdpEntity.class, pdpId);
-			if (droolsPdpEntity != null) {
-				logger.info("deletePdp: Removing PDP");
-				em.remove(droolsPdpEntity);
-			} else {
-				logger.info("deletePdp: PDP with ID='" + pdpId
-						+ "' not currently in DB");
-			}
-
-			/*
-			 * End transaction.
-			 */
-			em.getTransaction().commit();
-		} finally {
-			cleanup(em, "deletePdp");
-		}
-	
-		logger.info("deletePdp: Exiting");
-	
-	}
-	
-	/*
-	 * Normally this method should only be used in a JUnit test environment.
-	 * Manually deletes all records in droolsessionentity table.
-	 */
-	@Override
-	public void deleteAllSessions() {
-
-		logger.info("deleteAllSessions: Entering");
-
-		/*
-		 * Start transaction
-		 */
-		EntityManager em = emf.createEntityManager();
-
-		try {
-			em.getTransaction().begin();
-
-			Query droolsSessionListQuery = em
-					.createQuery("SELECT p FROM DroolsSessionEntity p");
-			@SuppressWarnings("unchecked")
-			List<DroolsSession> droolsSessionsList = droolsSessionListQuery.setLockMode(
-					LockModeType.NONE).setFlushMode(FlushModeType.COMMIT).getResultList();
-			logger.info("deleteAllSessions: Deleting " + droolsSessionsList.size() + " Sessions");
-			for (DroolsSession droolsSession : droolsSessionsList) {
-				logger.info("deleteAllSessions: Deleting droolsSession with pdpId="
-						+ droolsSession.getPdpId() + " and sessionId="
-						+ droolsSession.getSessionId());
-				em.remove(droolsSession);
-			}
-
-			/*
-			 * End transaction.
-			 */
-			em.getTransaction().commit();
-		} finally {
-			cleanup(em, "deleteAllSessions");
-		}		
-		logger.info("deleteAllSessions: Exiting");
-
-	}
-	
-	
-	/*
-	 * Close the specified EntityManager, rolling back any pending transaction
-	 *
-	 * @param em the EntityManager to close ('null' is OK)
-	 * @param method the invoking Java method (used for log messages)
-	 */
-	private static void cleanup(EntityManager em, String method)
-	{
-		if (em != null) {
-			if (em.isOpen()) {
-				if (em.getTransaction().isActive()) {
-					// there is an active EntityTransaction -- roll it back
-					try {
-						em.getTransaction().rollback();
-					} catch (Exception e) {
-						logger.error(method + ": Caught Exception attempting to rollback EntityTransaction, message='"
-										   + e.getMessage() + "'");
-					}
-				}
-
-				// now, close the EntityManager
-				try {
-					em.close();
-				} catch (Exception e) {
-					logger.error(method + ": Caught Exception attempting to close EntityManager, message='"
-									   + e.getMessage() + "'");
-				}
-			}
-		}
-	}
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/PersistenceFeature.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/PersistenceFeature.java
deleted file mode 100644
index 4d9c08a0..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/PersistenceFeature.java
+++ /dev/null
@@ -1,656 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-import java.io.IOException;
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.PreparedStatement;
-import java.sql.SQLException;
-import java.util.Date;
-import java.util.HashMap;
-import java.util.Map;
-import java.util.Properties;
-
-import javax.persistence.EntityManagerFactory;
-import javax.persistence.Persistence;
-
-import org.eclipse.persistence.config.PersistenceUnitProperties;
-import org.kie.api.KieServices;
-import org.kie.api.runtime.Environment;
-import org.kie.api.runtime.EnvironmentName;
-import org.kie.api.runtime.KieSession;
-import org.kie.api.runtime.KieSessionConfiguration;
-import org.openecomp.policy.common.ia.IntegrityAudit;
-import org.openecomp.policy.common.ia.IntegrityAuditProperties;
-import org.openecomp.policy.common.im.StateManagement;
-import org.openecomp.policy.common.logging.eelf.MessageCodes;
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-import org.openecomp.policy.common.logging.flexlogger.PropertyUtil;
-import org.openecomp.policy.drools.core.DroolsPDPIntegrityMonitor;
-import org.openecomp.policy.drools.core.PolicySessionFeatureAPI;
-import org.openecomp.policy.drools.core.IntegrityMonitorProperties;
-import org.openecomp.policy.drools.core.PolicyContainer;
-import org.openecomp.policy.drools.core.PolicySession;
-import org.openecomp.policy.drools.features.PolicyEngineFeatureAPI;
-import org.openecomp.policy.drools.im.PMStandbyStateChangeNotifier;
-import org.openecomp.policy.drools.system.PolicyEngine;
-
-import bitronix.tm.Configuration;
-import bitronix.tm.TransactionManagerServices;
-import bitronix.tm.resource.jdbc.PoolingDataSource;
-
-/**
- * If this feature is supported, there is a single instance of it.
- * It adds persistence to Drools sessions, but it is also intertwined with
- * active/standby state management and IntegrityMonitor. For now, they are
- * all treated as a single feature, but it would be nice to separate them.
- *
- * The bulk of the code here was once in other classes, such as
- * 'PolicyContainer' and 'Main'. It was moved here as part of making this
- * a separate optional feature.
- */
-public class PersistenceFeature implements PolicySessionFeatureAPI, PolicyEngineFeatureAPI
-{
-  // get an instance of logger
-  private static Logger logger =
-	FlexLogger.getLogger(PersistenceFeature.class);
-
-  // 'KieServices' singleton
-  static private KieServices kieServices = KieServices.Factory.get();
-
-  private static DroolsPdp myPdp;
-  private static Object myPdpSync = new Object();
-  private static DroolsPdpsElectionHandler electionHandler;
-
-  // indicates whether persistence has been disabled
-  private static boolean persistenceDisabled = false;
-
-  /*
-   * Used by JUnit testing to verify whether or not audit is running.
-   */
-  private static IntegrityAudit integrityAudit = null;
-
-  /**
-   * Lookup the adjunct for this feature that is associated with the
-   * specified PolicyContainer. If not found, create one.
-   *
-   * @param policyContainer the container whose adjunct we are looking up,
-   *	and possibly creating
-   * @return the associated 'ContainerAdjunct' instance, which may be new
-   */
-  private ContainerAdjunct getContainerAdjunct(PolicyContainer policyContainer)
-  {
-	Object rval = policyContainer.getAdjunct(this);
-	if (rval == null || ! (rval instanceof ContainerAdjunct))
-	  {
-		// adjunct does not exist, or has the wrong type (should never happen)
-		rval = new ContainerAdjunct(policyContainer);
-		policyContainer.setAdjunct(this, rval);
-	  }
-	return((ContainerAdjunct)rval);
-  }
-
-  /**************************/
-  /* 'FeatureAPI' interface */
-  /**************************/
-
-  /**
-   * {@inheritDoc}
-   */
-  @Override
-	public int getSequenceNumber()
-  {
-	return(1);
-  }
-
-  /**
-   * {@inheritDoc}
-   */
-  @Override
-	public void globalInit(String args[], String configDir)
-  {
-	// Initialization code associated with 'PolicyContainer'
-	DroolsPDPIntegrityMonitor droolsPdpIntegrityMonitor = null;
-	try
-	  {
-		droolsPdpIntegrityMonitor = DroolsPDPIntegrityMonitor.init(configDir);
-	  }
-	catch (Exception e)
-	  {
-		logger.error(MessageCodes.EXCEPTION_ERROR, e,
-					 "main", "DroolsPDPIntegrityMonitor.init()");
-	  }
-
-	initializePersistence(configDir, droolsPdpIntegrityMonitor);
-
-	// 1. Start Integrity Monitor (unless it was specifically disabled in the CORE layer
-		
-		
-	if (persistenceDisabled) {
-	  System.out.println("WARNING: Starting Engine with Persistance disabled");
-	  logger.warn("Starting Engine with Persistance disabled");
-	} else {
-	  DroolsPDPIntegrityMonitor im = null;
-	  //At this point the DroolsPDPIntegrityMonitor instance must exist
-	  try {
-		im = DroolsPDPIntegrityMonitor.getInstance();
-	  } catch (Exception e1) {
-		String msg = "policy-core startup failed to get DroolsPDPIntegrityMonitor instance:  \n" + e1;
-		System.out.println(msg);
-		e1.printStackTrace();
-	  }
-	  //Now get the StateManagement instance so we can register our observer
-	  StateManagement sm = im.getStateManager();
-			
-	  //Create an instance of the Observer
-	  PMStandbyStateChangeNotifier pmNotifier = new PMStandbyStateChangeNotifier();
-			
-	  //Register the PMStandbyStateChangeNotifier Observer
-	  sm.addObserver(pmNotifier);
-	}
-  }
-
-  /**
-   * This is a hook to create a new persistent KieSession.
-   *
-   * {@inheritDoc}
-   */
-  @Override
-	public KieSession activatePolicySession
-	(PolicyContainer policyContainer, String name, String kieBaseName)
-  {
-	return(getContainerAdjunct(policyContainer)
-		   .newPersistentKieSession(name, kieBaseName));
-  }
-
-  /**
-   * {@inheritDoc}
-   */
-  @Override
-	public void disposeKieSession(PolicySession policySession)
-  {
-	// TODO: There should be one data source per session
-	getContainerAdjunct(policySession.getPolicyContainer())
-	  .disposeKieSession();
-  }
-
-  /**
-   * {@inheritDoc}
-   */
-  @Override
-	public void destroyKieSession(PolicySession policySession)
-  {
-	// TODO: There should be one data source per session
-	getContainerAdjunct(policySession.getPolicyContainer())
-	  .destroyKieSession();
-  }
-	
-  /**
-   * {@inheritDoc}
-   */
-  @Override
-	public boolean afterStart(PolicyEngine engine) 
-  {
-	// ASSERTION: engine == PolicyEngine.manager
-    PolicyEngine.manager.lock();
-    return false;
-  }
-
-   /**
-	* {@inheritDoc}
-	*/
-   @Override
-	public boolean beforeActivate(PolicyEngine engine)
-  {
-	if (persistenceDisabled)
-	  {
-		return(false);
-	  }
-
-	// The following code will remove "old" Drools 'sessioninfo' records, so
-	// they aren't used to restore data to Drools sessions. This also has the
-	// useful side-effect of removing abandoned records as well.
-
-	// Fetch the timeout value, in seconds. If it is not specified or is
-	// less than or equal to 0, no records are removed.
-
-	String timeoutString = null;
-	int timeout = 0;
-	try
-	  {
-		timeoutString = DroolsPersistenceProperties.getProperty
-		  ("persistence.sessioninfo.timeout");
-		if (timeoutString != null)
-		  {
-			// timeout parameter is specified
-			timeout = Integer.valueOf(timeoutString);
-		  }
-	  }
-	catch (NumberFormatException e)
-	  {
-		logger.error("Invalid value for Drools persistence property "
-					 + "persistence.sessioninfo.timeout: "
-					 + timeoutString);
-	  }
-	if (timeout <= 0)
-	  {
-		// parameter is not specified, is <= 0, or is an invalid number
-		return(false);
-	  }
-
-	// if we reach this point, we are ready to remove old records from
-	// the database
-
-	Connection connection = null;
-	PreparedStatement statement = null;
-	try
-	  {
-		// fetch database parameters from properties
-
-		String url = DroolsPersistenceProperties.getProperty
-		  (DroolsPersistenceProperties.DB_URL);
-		String user = DroolsPersistenceProperties.getProperty
-		  (DroolsPersistenceProperties.DB_USER);
-		String password = DroolsPersistenceProperties.getProperty
-		  (DroolsPersistenceProperties.DB_PWD);
-
-		if (url != null && user != null && password != null)
-		  {
-			// get DB connection
-			connection = DriverManager.getConnection(url, user, password);
-
-			// create statement to delete old records
-			statement = connection.prepareStatement
-			  ("DELETE FROM sessioninfo WHERE "
-			   + "timestampdiff(second,lastmodificationdate,now()) > ?");
-			statement.setInt(1,timeout);
-
-			// execute statement
-			int count = statement.executeUpdate();
-			logger.info("Cleaning up sessioninfo table -- "
-						+ count + " records removed");
-		  }
-	  }
-	catch (SQLException e)
-	  {
-		logger.error("Clean up of sessioninfo table failed", e);
-	  }
-	finally
-	  {
-		// cleanup
-		if (statement != null)
-		  {
-			try
-			  {
-				statement.close();
-			  }
-			catch (SQLException e)
-			  {
-				logger.error("SQL connection close failed", e);
-			  }
-		  }
-		if (connection != null)
-		  {
-			try
-			  {
-				connection.close();
-			  }
-			catch (SQLException e)
-			  {
-				logger.error("SQL connection close failed", e);
-			  }
-		  }
-	  }
-	return(false);
-  }
-
-  /**************************/
-
-  /**
-   * @return 'true' if Drools persistence is disabled, and 'false' if not
-   */
-  static public boolean getPersistenceDisabled()
-  {
-	return(persistenceDisabled);
-  }
-
-  /**
-   * Read in the persistence properties, determine whether persistence is
-   * enabled or disabled, and initialize persistence if enabled.
-   */
-  private static void initializePersistence(String configDir, DroolsPDPIntegrityMonitor droolsPdpIntegrityMonitor)
-  {
-	  
-		try {
-			Properties pDrools = PropertyUtil.getProperties(configDir
-					+ "/droolsPersistence.properties");
-			DroolsPersistenceProperties.initProperties(pDrools);
-			Properties pXacml = PropertyUtil.getProperties(configDir
-					+ "/xacmlPersistence.properties");
-			XacmlPersistenceProperties.initProperties(pXacml);
-			if ("true".equals(pDrools.getProperty("persistenceDisabled"))) {
-				// 'persistenceDisabled' only relates to the 'drools'
-				// database. The fact that integrityMonitor/xacml depends upon
-				// persistence is an implementation detail there (which can't
-				// currently be disabled), and doesn't directly affect
-				// 'policy-core'.
-				persistenceDisabled = true;
-			} 
-		} catch (IOException e1) {
-			logger.error(MessageCodes.MISS_PROPERTY_ERROR, e1,
-					"initializePersistence");
-		}
-	  	  
-	    /*
-	     * Might as well handle the Integrity Monitor properties here, too.
-	     */
-	    try {
-		  Properties pIm =
-		    PropertyUtil.getProperties(configDir + "/IntegrityMonitor.properties");
-		  IntegrityMonitorProperties.initProperties(pIm);
-		  logger.info("initializePersistence: resourceName=" + IntegrityMonitorProperties.getProperty(IntegrityMonitorProperties.PDP_INSTANCE_ID));
-	    } catch (IOException e1) {
-		  logger.error(MessageCodes.MISS_PROPERTY_ERROR, e1, "initializePersistence");
-	    }
-	  
-
-		if (persistenceDisabled) {
-			// The persistence design is tied to 'DroolsPdpsElectionHandler',
-			// so we should bypass that as well. This also means that we
-			// won't get active/standby notifications, so we need to go
-			// into the 'active' state in order to have any 'PolicySession'
-			// instances.
-			return;
-		}
-
-	    DroolsPdpsConnector conn = getDroolsPdpsConnector("ncompPU");
-		String uniquePdpId = IntegrityMonitorProperties.getProperty(IntegrityMonitorProperties.PDP_INSTANCE_ID);
-		if(uniquePdpId == null){
-			throw new NullPointerException();
-		}
-		
-		/*
-		 * In a JUnit test environment, one or more PDPs may already have been
-		 * inserted in the DB, so we need to check for this.
-		 */
-		DroolsPdp existingPdp = conn.getPdp(uniquePdpId);
-		if (existingPdp != null) {
-			System.out.println("Found existing PDP record, pdpId="
-					+ existingPdp.getPdpId() + ", isDesignated="
-					+ existingPdp.isDesignated() + ", updatedDate="
-					+ existingPdp.getUpdatedDate());
-			myPdp = existingPdp;
-		}
-		
-	    /*
-	     * Kick off integrity audit for Drools DB.
-	     */
-	    startIntegrityAudit(configDir);
-				
-		synchronized(myPdpSync){
-			if(myPdp == null){
-
-				myPdp = new DroolsPdpImpl(uniquePdpId,false,4,new Date());	
-			}
-			if(myPdp != null){
-				String site_name = "";
-				site_name = IntegrityMonitorProperties.getProperty(IntegrityMonitorProperties.SITE_NAME);
-				if (site_name == null) {
-					site_name = "";
-				}else{
-					site_name = site_name.trim();
-				}
-				myPdp.setSiteName(site_name);
-			}
-			if(electionHandler == null){
-		electionHandler = new DroolsPdpsElectionHandler(conn,myPdp,droolsPdpIntegrityMonitor);
-			}
-		}
-		Configuration bitronixConfiguration = TransactionManagerServices.getConfiguration();
-		bitronixConfiguration.setJournal(null);
-		bitronixConfiguration.setServerId(uniquePdpId);
-		System.out.println("\n\nThis controller is a standby, waiting to be chosen as primary...\n\n");
-		logger.info("\n\nThis controller is a standby, waiting to be chosen as primary...\n\n");
-  }
-
-	private static void startIntegrityAudit(String configDir) {
-
-		logger.info("startIntegrityAudit: Entering, configDir='" + configDir
-				+ "'");
-
-		/*
-		 * Initialize Integrity Audit properties. file.
-		 */
-		try {
-
-			String resourceName = IntegrityMonitorProperties
-					.getProperty(IntegrityMonitorProperties.PDP_INSTANCE_ID);
-
-			/*
-			 * Load properties for auditing of Drools DB.
-			 */
-			Properties droolsPia = PropertyUtil.getProperties(configDir
-					+ "/IntegrityMonitor.properties");
-
-			/*
-			 * Supplement properties specific to the IntegrityMonitor (e.g.
-			 * site_name, node_type, resource.name) with properties specific to
-			 * persisting Drools DB entities (see
-			 * ../policy-core/src/main/resources/persistence.xml)
-			 * 
-			 * Note: integrity_audit_period_seconds is defined in
-			 * IntegrityMonitor.properties, rather than creating a whole new
-			 * "IntegrityAudit.properties" file for just one property.
-			 */
-			droolsPia
-					.setProperty(
-							IntegrityAuditProperties.DB_DRIVER,
-							DroolsPersistenceProperties
-									.getProperty(DroolsPersistenceProperties.DB_DRIVER));
-			droolsPia.setProperty(IntegrityAuditProperties.DB_PWD,
-					DroolsPersistenceProperties
-							.getProperty(DroolsPersistenceProperties.DB_PWD));
-			droolsPia.setProperty(IntegrityAuditProperties.DB_URL,
-					DroolsPersistenceProperties
-							.getProperty(DroolsPersistenceProperties.DB_URL));
-			droolsPia.setProperty(IntegrityAuditProperties.DB_USER,
-					DroolsPersistenceProperties
-							.getProperty(DroolsPersistenceProperties.DB_USER));
-
-			/*
-			 * Start audit for Drools DB.
-			 */
-			integrityAudit = new IntegrityAudit(
-					resourceName, "auditDroolsPU", droolsPia);
-			integrityAudit.startAuditThread();
-
-		} catch (IOException e1) {
-			logger.error(
-					MessageCodes.MISS_PROPERTY_ERROR,
-					e1,
-					"initializePersistence: IntegrityAuditProperties: "
-							+ e1.getMessage());
-		} catch (Exception e2) {
-			logger.error(
-					MessageCodes.EXCEPTION_ERROR,
-					e2,
-					"initializePersistence: IntegrityAuditProperties: "
-							+ e2.getMessage());
-		}
-
-		logger.debug("startIntegrityAudit: Exiting");
-
-	}
-  
-	/*
-	 * Moved code to instantiate a JpaDroolsPdpsConnector object from main() to
-	 * this method, so it can also be accessed from StandbyStateChangeNotifier
-	 * class.
-	 */
-	public static DroolsPdpsConnector getDroolsPdpsConnector(String pu) {
-
-		Map<String, Object> propMap = new HashMap<String, Object>();
-		propMap.put("javax.persistence.jdbc.driver", DroolsPersistenceProperties
-				.getProperty(DroolsPersistenceProperties.DB_DRIVER));
-		propMap.put("javax.persistence.jdbc.url",
-				DroolsPersistenceProperties.getProperty(DroolsPersistenceProperties.DB_URL));
-		propMap.put("javax.persistence.jdbc.user", DroolsPersistenceProperties
-				.getProperty(DroolsPersistenceProperties.DB_USER));
-		propMap.put("javax.persistence.jdbc.password",
-				DroolsPersistenceProperties.getProperty(DroolsPersistenceProperties.DB_PWD));
-
-		EntityManagerFactory emf = Persistence.createEntityManagerFactory(
-				pu, propMap);
-		DroolsPdpsConnector conn = new JpaDroolsPdpsConnector(emf);
-
-		return conn;
-	}
-
-	/*
-	 * IntegrityAudit instance is needed by JUnit testing to ascertain whether
-	 * or not audit is running.
-	 */
-	public static IntegrityAudit getIntegrityAudit() {
-
-		return integrityAudit;
-
-	}
-
-  /* ============================================================ */
-
-  /**
-   * Each instance of this class is a logical extension of a 'PolicyContainer'
-   * instance. It's reference is stored in the 'adjuncts' table within the
-   * 'PolicyContainer', and will be garbage-collected with the container.
-   */
-  class ContainerAdjunct
-  {
-	// this is the 'PolicyContainer' instance that this adjunct is extending
-	private PolicyContainer policyContainer;
-	private PoolingDataSource ds = null;
-
-	/**
-	 * Constructor - initialize a new 'ContainerAdjunct'
-	 *
-	 * @param policyContainer the 'PolicyContainer' instance this adjunct
-	 *		is extending
-	 */
-	ContainerAdjunct(PolicyContainer policyContainer)
-	{
-	  this.policyContainer = policyContainer;
-	}
-
-	/**
-	 * Create a new persistent KieSession. If there is already a corresponding
-	 * entry in the database, it is used to initialize the KieSession. If not,
-	 * a completely new session is created.
-	 *
-	 * @param name the name of the KieSession (which is also the name of
-	 *	the associated PolicySession)
-	 * @param kieBaseName the name of the 'KieBase' instance containing
-	 *	this session
-	 * @return a new KieSession with persistence enabled (if persistence is
-	 *	disabled, 'null' is returned
-	 */
-	private KieSession newPersistentKieSession(String name, String kieBaseName)
-	{
-	  if (persistenceDisabled)
-		{
-		  return(null);
-		}
-	  long desiredSessionId = -1;
-	  synchronized (myPdpSync) {
-		
-	
-	
-		for(DroolsSession droolsSession : electionHandler.getSessions()){
-		  if(droolsSession.getSessionName().equals(name)){
-			desiredSessionId = droolsSession.getSessionId();
-		  }
-		}
-	  }
-	  System.out.println("\n\nThis controller is primary... coming up with session "+desiredSessionId+"\n\n");
-	  logger.info("\n\nThis controller is primary... coming up with session "+desiredSessionId+"\n\n");
-	  Map<String, Object> props = new HashMap<String, Object>();
-	  props.put("URL", DroolsPersistenceProperties.getProperty(DroolsPersistenceProperties.DB_URL));
-	  props.put("user", DroolsPersistenceProperties.getProperty(DroolsPersistenceProperties.DB_USER));
-	  props.put("password", DroolsPersistenceProperties.getProperty(DroolsPersistenceProperties.DB_PWD));
-	  props.put("dataSource",DroolsPersistenceProperties.getProperty(DroolsPersistenceProperties.DB_DATA_SOURCE));
-	  logger.info("getPolicySession:session does not exist -- attempt to create one with name " + name);
-	  // session does not exist -- attempt to create one
-	  System.getProperties().put("java.naming.factory.initial","bitronix.tm.jndi.BitronixInitialContextFactory");
-	  Environment env = kieServices.newEnvironment();
-	  //kContainer.newKieBase(null);
-	  ds = new PoolingDataSource();			
-	  ds.setUniqueName("jdbc/BitronixJTADataSource"+name);
-	  ds.setClassName( (String)props.remove("dataSource"));
-	  //ds.setClassName( "org.h2.Driver" );
-	  ds.setMaxPoolSize( 3 );
-	  ds.setIsolationLevel("SERIALIZABLE");
-	  ds.setAllowLocalTransactions( true );
-	  //ds.getDriverProperties().put( "user", "sa" );
-	  //ds.getDriverProperties().put( "password", "" );
-	  //ds.getDriverProperties().put( "URL", "jdbc:h2:tcp://localhost/drools" );
-	  ds.getDriverProperties().putAll(props);
-	  ds.init();	
-	  Properties emfProperties = new Properties();
-	  emfProperties.setProperty(PersistenceUnitProperties.JTA_DATASOURCE, "jdbc/BitronixJTADataSource"+name);
-	  env.set(EnvironmentName.ENTITY_MANAGER_FACTORY, Persistence.createEntityManagerFactory("ncompsessionsPU",emfProperties));
-	  env.set(EnvironmentName.TRANSACTION_MANAGER,TransactionManagerServices.getTransactionManager());
-	  KieSessionConfiguration kConf = KieServices.Factory.get().newKieSessionConfiguration();
-	  KieSession kieSession;
-	  try{
-		kieSession = kieServices.getStoreServices().loadKieSession(desiredSessionId, policyContainer.getKieContainer().getKieBase(kieBaseName), kConf, env);
-		System.out.println("LOADING We can load session "+desiredSessionId+", going to create a new one");
-		logger.info("LOADING We can load session "+desiredSessionId+", going to create a new one");
-	  }catch(Exception e){
-		System.out.println("LOADING We cannot load session "+desiredSessionId+", going to create a new one");
-
-		logger.info("LOADING We cannot load session "+desiredSessionId+", going to create a new one");
-		kieSession = kieServices.getStoreServices().newKieSession(policyContainer.getKieContainer().getKieBase(kieBaseName), null, env);
-		System.out.println("LOADING CREATED "+kieSession.getIdentifier());
-		logger.info("LOADING CREATED "+kieSession.getIdentifier());
-	  }
-	  synchronized (myPdpSync) {
-		myPdp.setSessionId(name,kieSession.getIdentifier());
-		electionHandler.updateMyPdp();
-	  }
-	  return(kieSession);
-	}
-
-	private void disposeKieSession()
-	{
-	if (ds != null)
-	  {
-		ds.close();
-		ds = null;
-	  }
-	}
-
-	private void destroyKieSession()
-	{
-	  // does the same thing as 'dispose'
-	  disposeKieSession();
-	}
-  }
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/ThreadRunningChecker.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/ThreadRunningChecker.java
deleted file mode 100644
index ccec824c..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/ThreadRunningChecker.java
+++ /dev/null
@@ -1,26 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-public interface ThreadRunningChecker {
-	public void checkThreadStatus();
-
-}
diff --git a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/XacmlPersistenceProperties.java b/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/XacmlPersistenceProperties.java
deleted file mode 100644
index 7e2388e5..00000000
--- a/policy-persistence/src/main/java/org/openecomp/policy/drools/persistence/XacmlPersistenceProperties.java
+++ /dev/null
@@ -1,65 +0,0 @@
-/*-
- * ============LICENSE_START=======================================================
- * policy-persistence
- * ================================================================================
- * Copyright (C) 2017 AT&T Intellectual Property. All rights reserved.
- * ================================================================================
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- * 
- *      http://www.apache.org/licenses/LICENSE-2.0
- * 
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- * ============LICENSE_END=========================================================
- */
-
-package org.openecomp.policy.drools.persistence;
-
-import java.util.Properties;
-
-import org.openecomp.policy.common.logging.flexlogger.FlexLogger;
-import org.openecomp.policy.common.logging.flexlogger.Logger;
-
-
-public class XacmlPersistenceProperties {
-	// get an instance of logger 
-	private static Logger  logger = FlexLogger.getLogger(XacmlPersistenceProperties.class);	
-	/*
-	 * xacmlPersistence.properties parameter key values
-	 */
-	public static final String DB_DRIVER = "javax.persistence.jdbc.driver";
-	public static final String DB_DATA_SOURCE  = "hibernate.dataSource";
-	public static final String DB_URL = "javax.persistence.jdbc.url";
-	public static final String DB_USER = "javax.persistence.jdbc.user";
-	public static final String DB_PWD = "javax.persistence.jdbc.password";
-		
-	private static Properties properties = null;
-	/*
-	 * Initialize the parameter values from the droolsPersitence.properties file values
-	 * 
-	 * This is designed so that the Properties object is obtained from the xacmlPersistence.properties
-	 * file and then is passed to this method to initialize the value of the parameters.
-	 * This allows the flexibility of JUnit tests using getProperties(filename) to get the
-	 * properties while runtime methods can use getPropertiesFromClassPath(filename).
-	 * 
-	 */
-	public static void initProperties (Properties prop){
-		logger.info("XacmlPersistenceProperties.initProperties(Properties): entry");
-		logger.info("\n\nXacmlPersistenceProperties.initProperties: Properties = \n" + prop + "\n\n");
-		
-		properties = prop;
-	}
-
-	public static String getProperty(String key){
-		return properties.getProperty(key);
-	}
-	
-	public static Properties getProperties() {
-		return properties;
-	}
-}
diff --git a/policy-persistence/src/main/resources/META-INF/services/org.openecomp.policy.drools.core.PolicySessionFeatureAPI b/policy-persistence/src/main/resources/META-INF/services/org.openecomp.policy.drools.core.PolicySessionFeatureAPI
deleted file mode 100644
index 540a4bd4..00000000
--- a/policy-persistence/src/main/resources/META-INF/services/org.openecomp.policy.drools.core.PolicySessionFeatureAPI
+++ /dev/null
@@ -1 +0,0 @@
-org.openecomp.policy.drools.persistence.PersistenceFeature
diff --git a/policy-persistence/src/main/resources/META-INF/services/org.openecomp.policy.drools.features.PolicyEngineFeatureAPI b/policy-persistence/src/main/resources/META-INF/services/org.openecomp.policy.drools.features.PolicyEngineFeatureAPI
deleted file mode 100644
index 540a4bd4..00000000
--- a/policy-persistence/src/main/resources/META-INF/services/org.openecomp.policy.drools.features.PolicyEngineFeatureAPI
+++ /dev/null
@@ -1 +0,0 @@
-org.openecomp.policy.drools.persistence.PersistenceFeature