gCubeSystem
/
document-store-lib
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

add method shutdown 

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-publishing/document-store-lib@146352 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Alessandro Pieve 2017-03-27 08:52:58 +00:00
parent 5c3fdbbe6b
commit f500448df5
3 changed files with 10 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
pom.xml
View File

@ -9,7 +9,7 @@
<groupId>org.gcube.data.publishing</groupId>
<artifactId>document-store-lib</artifactId>
<version>1.6.0-SNAPSHOT</version>
<version>1.5.1-SNAPSHOT</version>
<name>Document Store Lib</name>
<description>Allow to persist data in NoSQL Document Store Databases.
Discover Model dynamically.

1
src/main/java/org/gcube/documentstore/persistence/PersistenceBackendFactory.java
View File

@ -56,6 +56,7 @@ public abstract class PersistenceBackendFactory {
}
public static void addRecordPackage(Package packageObject) {
logger.trace("Package:{}",packageObject.toString());
RecordUtility.addRecordPackage(packageObject);
}

8
src/main/java/org/gcube/documentstore/records/RecordUtility.java
View File

@ -47,6 +47,7 @@ public class RecordUtility {
try {
List<Class<?>> classes = ReflectionUtility.getClassesForPackage(packageObject);
for(Class<?> clz : classes){
logger.trace("found a class:{}",clz.getSimpleName());
if(Record.class.isAssignableFrom(clz)){
addRecordClass((Class<? extends Record>) clz);
}
@ -73,6 +74,7 @@ public class RecordUtility {
discoveredRecordType = record.getRecordType();
if(!recordClassesFound.containsKey(discoveredRecordType)){
logger.trace("Not containsKey discoveredRecordType:{}, cls:{}",discoveredRecordType.toString(),cls.toString());
recordClassesFound.put(discoveredRecordType, cls);
}
@ -85,6 +87,7 @@ public class RecordUtility {
protected static void addAggregatedRecordClass(Class<? extends AggregatedRecord<?,?>> cls){
if(Modifier.isAbstract(cls.getModifiers())){
logger.trace("is abstract cls:{}",cls);
return;
}
@ -148,6 +151,11 @@ public class RecordUtility {
public static Class<? extends AggregatedRecord<?,?>> getAggregatedRecordClass(String recordType) throws ClassNotFoundException {
logger.debug("////----recordType:{}",recordType);
logger.debug("////----:{}",getAggregatedRecordClassesFound().toString());
logger.error("find {} class for {}.",
AggregatedRecord.class.getSimpleName(), recordType);
if(getAggregatedRecordClassesFound().containsKey(recordType)){
logger.trace("record type {},getAggregatedRecordClassesFound {}",recordType,getAggregatedRecordClassesFound(),getAggregatedRecordClassesFound().get(recordType));