Revision 4a13ca5f
Added by Andreas Kohlbecker over 8 years ago
src/main/java/org/cybertaxonomy/utis/checklist/EEA_BDC_Client.java | ||
---|---|---|
11 | 11 |
import org.cybertaxonomy.utis.client.ServiceProviderInfo; |
12 | 12 |
import org.cybertaxonomy.utis.query.TinkerPopClient; |
13 | 13 |
import org.cybertaxonomy.utis.store.Neo4jStore; |
14 |
import org.cybertaxonomy.utis.store.Neo4jStoreUpdater;
|
|
14 |
import org.cybertaxonomy.utis.store.Neo4jStoreManager;
|
|
15 | 15 |
import org.cybertaxonomy.utis.tnr.msg.Classification; |
16 | 16 |
import org.cybertaxonomy.utis.tnr.msg.NameType; |
17 | 17 |
import org.cybertaxonomy.utis.tnr.msg.Query; |
... | ... | |
36 | 36 |
import com.tinkerpop.pipes.util.FastNoSuchElementException; |
37 | 37 |
import com.tinkerpop.pipes.util.structures.Table; |
38 | 38 |
|
39 |
public class EEA_BDC_Client extends AggregateChecklistClient<TinkerPopClient> { |
|
39 |
public class EEA_BDC_Client extends AggregateChecklistClient<TinkerPopClient> implements UpdatableStoreInfo {
|
|
40 | 40 |
|
41 | 41 |
/** |
42 | 42 |
* |
... | ... | |
140 | 140 |
return true; |
141 | 141 |
} |
142 | 142 |
|
143 |
/** |
|
144 |
* {@inheritDoc} |
|
145 |
*/ |
|
146 |
@Override |
|
147 |
public String getTestUrl() { |
|
148 |
return SPECIES_RDF_FILE_URL; |
|
149 |
} |
|
150 |
|
|
151 |
/** |
|
152 |
* {@inheritDoc} |
|
153 |
*/ |
|
154 |
@Override |
|
155 |
public int pollIntervalMinutes() { |
|
156 |
return CHECK_UPDATE_MINUTES; |
|
157 |
} |
|
158 |
|
|
159 |
/** |
|
160 |
* {@inheritDoc} |
|
161 |
*/ |
|
162 |
@Override |
|
163 |
public String[] updatableResources() { |
|
164 |
return new String[] {SPECIES_RDF_FILE_URL, TAXONOMY_RDF_FILE_URL, LEGALREFS_RDF_FILE_URL, REFERENCES_RDF_FILE_URL}; |
|
165 |
} |
|
166 |
|
|
143 | 167 |
@Override |
144 | 168 |
public void initQueryClient() { |
145 | 169 |
|
146 |
Neo4jStore neo4jStore; |
|
147 |
try { |
|
148 |
neo4jStore = new Neo4jStore(); |
|
149 |
Neo4jStoreUpdater updater = new Neo4jStoreUpdater(neo4jStore, SPECIES_RDF_FILE_URL); |
|
150 |
updater.addResources(SPECIES_RDF_FILE_URL, TAXONOMY_RDF_FILE_URL, LEGALREFS_RDF_FILE_URL, REFERENCES_RDF_FILE_URL); |
|
151 |
updater.watch(CHECK_UPDATE_MINUTES); |
|
152 |
} catch (Exception e1) { |
|
153 |
throw new RuntimeException("Creation of Neo4jStore failed", e1); |
|
154 |
} |
|
155 |
queryClient = new TinkerPopClient(neo4jStore); |
|
170 |
Neo4jStore neo4jStore = Neo4jStoreManager.provideStoreFor(this); |
|
171 |
queryClient = new TinkerPopClient(neo4jStore); |
|
156 | 172 |
} |
157 | 173 |
|
158 | 174 |
@Override |
Also available in: Unified diff
implementation of a manager for neo4j stores, the ClientManager has been turned into ClientFactory