Revision 6427
Added by ben leinfelder about 13 years ago
| src/edu/ucsb/nceas/metacat/dataone/CNodeService.java | ||
|---|---|---|
| 155 | 155 |
nodeMap = |
| 156 | 156 |
PropertyService.getProperty("dataone.hazelcast.processCluster.nodesMap");
|
| 157 | 157 |
systemMetadataMap = |
| 158 |
PropertyService.getProperty("dataone.hazelcast.storageCluster.systemMetadata");
|
|
| 159 |
taskIds = |
|
| 160 |
PropertyService.getProperty("dataone.hazelcast.storageCluster.tasksIdGenerator");
|
|
| 158 |
PropertyService.getProperty("dataone.hazelcast.storageCluster.systemMetadataMap");
|
|
| 161 | 159 |
pendingTasksQueue = |
| 162 | 160 |
PropertyService.getProperty("dataone.hazelcast.replicationPendingTasks");
|
| 163 | 161 |
|
| 164 | 162 |
// Become a DataONE-process cluster client |
| 165 |
String[] addresses = addressList.split(",");
|
|
| 166 |
hzClient = |
|
| 167 |
HazelcastClient.newHazelcastClient(this.groupName, this.groupPassword, addresses); |
|
| 168 |
nodes = hzClient.getMap(nodeMap); |
|
| 169 |
pendingReplicationTasks = hzClient.getMap(pendingTasksQueue); |
|
| 163 |
//TODO: where should this be? |
|
| 164 |
// String[] addresses = addressList.split(",");
|
|
| 165 |
// hzClient = |
|
| 166 |
// HazelcastClient.newHazelcastClient(this.groupName, this.groupPassword, addresses); |
|
| 167 |
// nodes = hzClient.getMap(nodeMap); |
|
| 168 |
// pendingReplicationTasks = hzClient.getMap(pendingTasksQueue); |
|
| 170 | 169 |
|
| 171 | 170 |
// Get a reference to the shared system metadata map as a cluster member |
| 172 | 171 |
systemMetadata = Hazelcast.getMap(systemMetadataMap); |
Also available in: Unified diff
comment out processCluster connections that use hzClient until that is finalized