Revision 4a13ca5f
Added by Andreas Kohlbecker over 8 years ago
| src/main/java/org/cybertaxonomy/utis/store/Neo4jStoreUpdater.java | ||
|---|---|---|
| 102 | 102 |
|
| 103 | 103 |
@Override |
| 104 | 104 |
public void run() {
|
| 105 |
updateIfNeeded(); |
|
| 106 |
try {
|
|
| 107 |
sleep(interval_ms); |
|
| 108 |
} catch (InterruptedException e) {
|
|
| 109 |
logger.info("Neo4jStoreUpdater has been interrupted");
|
|
| 105 |
boolean interrupted = false; |
|
| 106 |
while(!interrupted) {
|
|
| 107 |
updateIfNeeded(); |
|
| 108 |
try {
|
|
| 109 |
sleep(interval_ms); |
|
| 110 |
} catch (InterruptedException e) {
|
|
| 111 |
logger.info("Neo4jStoreUpdater has been interrupted");
|
|
| 112 |
interrupted = true; |
|
| 113 |
} |
|
| 110 | 114 |
} |
| 111 | 115 |
} |
| 112 | 116 |
}; |
| 117 |
updateThread.setName(Neo4jStoreUpdater.class.getSimpleName()); |
|
| 113 | 118 |
updateThread.start(); |
| 114 | 119 |
} |
| 115 | 120 |
|
Also available in: Unified diff
implementation of a manager for neo4j stores, the ClientManager has been turned into ClientFactory