diff options
Diffstat (limited to 'jar/src/main/java/org/onap/music/eelf/healthcheck/MusicHealthCheck.java')
| -rw-r--r-- | jar/src/main/java/org/onap/music/eelf/healthcheck/MusicHealthCheck.java | 175 |
1 files changed, 0 insertions, 175 deletions
diff --git a/jar/src/main/java/org/onap/music/eelf/healthcheck/MusicHealthCheck.java b/jar/src/main/java/org/onap/music/eelf/healthcheck/MusicHealthCheck.java deleted file mode 100644 index 1f4abea1..00000000 --- a/jar/src/main/java/org/onap/music/eelf/healthcheck/MusicHealthCheck.java +++ /dev/null @@ -1,175 +0,0 @@ -/* - * ============LICENSE_START========================================== - * org.onap.music - * =================================================================== - * Copyright (c) 2017 AT&T Intellectual Property - * =================================================================== - * 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.onap.music.eelf.healthcheck; - -import java.io.BufferedReader; -import java.io.IOException; -import java.io.InputStreamReader; -import java.util.Iterator; - - -import java.util.HashMap; -import java.util.Iterator; -import java.util.List; -import java.util.Map; -import java.util.UUID; - -import org.mindrot.jbcrypt.BCrypt; -import org.onap.music.datastore.PreparedQueryObject; -import org.onap.music.datastore.jsonobjects.JsonOnboard; -import org.onap.music.eelf.logging.EELFLoggerDelegate; -import org.onap.music.eelf.logging.format.AppMessages; -import org.onap.music.eelf.logging.format.ErrorSeverity; -import org.onap.music.eelf.logging.format.ErrorTypes; -import org.onap.music.exceptions.MusicLockingException; -import org.onap.music.lockingservice.MusicLockingService; -import org.onap.music.main.CachingUtil; -import org.onap.music.main.MusicCore; -import org.onap.music.main.MusicUtil; -import org.onap.music.main.ResultType; -import com.datastax.driver.core.DataType; -import com.datastax.driver.core.ResultSet; - - - - -/** - * @author inam - * - */ -public class MusicHealthCheck { - - private static EELFLoggerDelegate logger = EELFLoggerDelegate.getLogger(MusicUtil.class); - - private String cassandrHost; - private String zookeeperHost; - - - - - - - - - public String getCassandraStatus() { - logger.info(EELFLoggerDelegate.applicationLogger,"Getting Status for Cassandra"); - if(this.getAdminKeySpace()) { - return "ACTIVE"; - }else { - logger.info(EELFLoggerDelegate.applicationLogger,"Cassandra Service is not responding"); - return "INACTIVE"; - } - } - - - private Boolean getAdminKeySpace() { - - String appName = ""; - - PreparedQueryObject pQuery = new PreparedQueryObject(); - pQuery.appendQueryString( - "select * from admin.keyspace_master"); - //pQuery.addValue(MusicUtil.convertToActualDataType(DataType.text(), appName)); - try { - ResultSet rs = MusicCore.get(pQuery); - - if(rs != null) { - return Boolean.TRUE; - }else { - return Boolean.FALSE; - } - } catch (Exception e) { - logger.error(EELFLoggerDelegate.errorLogger,e.getMessage(),AppMessages.CASSANDRACONNECTIVITY, ErrorTypes.CONNECTIONERROR, ErrorSeverity.CRITICAL); - } - - return Boolean.FALSE; - - - } - - public String getZookeeperStatus() { - - - String host = MusicUtil.getMyZkHost(); - logger.info(EELFLoggerDelegate.applicationLogger,"Getting Status for Zookeeper Host: "+host); - try { - MusicLockingService lockingService = MusicCore.getLockingServiceHandle(); - //additionally need to call the ZK to create,aquire and delete lock - } catch (MusicLockingException e) { - logger.error(EELFLoggerDelegate.errorLogger,e.getMessage(),AppMessages.LOCKINGERROR, ErrorTypes.CONNECTIONERROR, ErrorSeverity.CRITICAL); - return "INACTIVE"; - } - - logger.info(EELFLoggerDelegate.applicationLogger,"Zookeeper is Active and Running"); - return "ACTIVE"; - - //return "Zookeeper is not responding"; - - } - - - - - public String getCassandrHost() { - return cassandrHost; - } - - - - - public void setCassandrHost(String cassandrHost) { - this.cassandrHost = cassandrHost; - } - - - - - public String getZookeeperHost() { - return zookeeperHost; - } - - - - - public void setZookeeperHost(String zookeeperHost) { - this.zookeeperHost = zookeeperHost; - } - - - - - - - - - - - - - - - - - - - -} |