diff options
| author |   Vikram Potturi(apotturi) <vp9004@att.com> | 2018-05-21 20:06:08 -0400 |
|---|---|---|
| committer | Vikram Potturi(apotturi) <vp9004@att.com> | 2018-05-21 20:06:08 -0400 |
| commit | b1dc42528a3e7e89187fac220a2f9be3e4151caf (patch) | |
| tree | bc5a9caddf25006107f60f824e40f82f8d89ff6d | |
| parent | 067e18e954ffd6bbf90416e6922c06e5a43b49df (diff) | |
Added changes for Zookeeper node healthcheckv2.5.5release-2.5.3
Change-Id: Ib25342cebfc95a217dedc2588f2fb1284b1ef03f
Issue-ID: MUSIC-73
Signed-off-by: Vikram Potturi(apotturi) <vp9004@att.com>
| -rw-r--r-- | jar/pom.xml | 2 | ||||
| -rw-r--r-- | jar/src/main/java/org/onap/music/lockingservice/MusicLockingService.java | 18 | ||||
| -rw-r--r-- | jar/src/main/webapp/WEB-INF/classes/project.properties | 2 |
3 files changed, 20 insertions, 2 deletions
diff --git a/jar/pom.xml b/jar/pom.xml index d2d74523..6627b002 100644 --- a/jar/pom.xml +++ b/jar/pom.xml @@ -25,7 +25,7 @@ <groupId>org.onap.music</groupId> <artifactId>MUSIC</artifactId> <packaging>jar</packaging> - <version>2.5.5</version> + <version>2.5.6</version> <description> This is the MUSIC interface, packaged as a jar file. </description> diff --git a/jar/src/main/java/org/onap/music/lockingservice/MusicLockingService.java b/jar/src/main/java/org/onap/music/lockingservice/MusicLockingService.java index ae026903..29f23158 100644 --- a/jar/src/main/java/org/onap/music/lockingservice/MusicLockingService.java +++ b/jar/src/main/java/org/onap/music/lockingservice/MusicLockingService.java @@ -34,6 +34,7 @@ import org.onap.music.eelf.logging.format.ErrorTypes; import org.onap.music.exceptions.MusicLockingException; import org.onap.music.exceptions.MusicServiceException; import org.onap.music.main.MusicUtil; +import java.util.concurrent.TimeUnit; public class MusicLockingService implements Watcher { @@ -76,6 +77,23 @@ public class MusicLockingService implements Watcher { logger.error(EELFLoggerDelegate.errorLogger, e.getMessage(),AppMessages.UNKNOWNERROR, ErrorSeverity.ERROR, ErrorTypes.LOCKINGERROR); } } + + public MusicLockingService(int timeout) throws MusicServiceException { + CountDownLatch connectedSignal1 = new CountDownLatch(1); + try { + ZooKeeper zk1 = new ZooKeeper(MusicUtil.getMyZkHost(), SESSION_TIMEOUT, this); + connectedSignal1.await(timeout, TimeUnit.SECONDS); + if(!zk1.getState().isConnected()) { + throw new MusicServiceException("Unable to Connect. Some nodes are down."); + } + } catch (IOException e ) { + logger.error(EELFLoggerDelegate.errorLogger, e.getMessage(),AppMessages.IOERROR, ErrorSeverity.ERROR, ErrorTypes.CONNECTIONERROR); + throw new MusicServiceException("IO Error has occured" + e.getMessage()); + } catch (InterruptedException e) { + logger.error(EELFLoggerDelegate.errorLogger, e.getMessage(),AppMessages.EXECUTIONINTERRUPTED, ErrorSeverity.ERROR, ErrorTypes.LOCKINGERROR); + throw new MusicServiceException("Exception Occured " + e.getMessage()); + } + } public void createLockaIfItDoesNotExist(String lockName) { if (!zkLockHandle.checkIfLockExists(lockName)) { diff --git a/jar/src/main/webapp/WEB-INF/classes/project.properties b/jar/src/main/webapp/WEB-INF/classes/project.properties index 3b6d2283..cb51134a 100644 --- a/jar/src/main/webapp/WEB-INF/classes/project.properties +++ b/jar/src/main/webapp/WEB-INF/classes/project.properties @@ -1,4 +1,4 @@ -version=2.5.3 +version=2.5.5 artifactId=MUSIC music.properties=/opt/app/music/etc/music.properties |