- private static final Config readAkkaConfiguration() {
- File defaultConfigFile = new File(AKKA_CONF_PATH);
- Preconditions.checkState(defaultConfigFile.exists(), "akka.conf is missing");
- return ConfigFactory.parseFile(defaultConfigFile);
+ LOG.info("Destroy data store instance of type : {}", dataStore.getActorContext().getDataStoreType());
+
+ if(createdInstances.remove(dataStore)){
+ if(createdInstances.size() == 0){
+ if(actorSystem != null) {
+ actorSystem.shutdown();
+ try {
+ actorSystem.awaitTermination(Duration.create(10, TimeUnit.SECONDS));
+ } catch (Exception e) {
+ LOG.warn("Error awaiting actor termination", e);
+ }
+ actorSystem = null;
+ }
+ }
+ }