Metacat

    private static HazelcastClient hzClient = null;

    private static String hzSystemMetadata = null;

    private static String hzObjectPath = null;

    private static int waitingTime = IndexGenerator.WAITTIME;

    private static int maxAttempts = IndexGenerator.MAXWAITNUMBER;

    private static IMap<Identifier, SystemMetadata> systemMetadataMap = null;

    private static IMap<Identifier, String> objectPathMap = null;

    /* The name of the identifiers set */

    private static String identifiersSetName = IDENTIFIERSETNAME;

    /* The Hazelcast distributed identifiers set */

            log.warn("DistributedMapFactory.startHazelCastClient - couldn't read the name of the identifiersSet from the metacat.properties file since : "+e.getMessage()+". Default values will be used");

            identifiersSetName = IDENTIFIERSETNAME;

        }

        hzSystemMetadata = Settings.getConfiguration().getString(

                "dataone.hazelcast.storageCluster.systemMetadataMap");

        hzObjectPath = Settings.getConfiguration().getString(

        return identifiersSet;

    }

}

import org.dataone.service.types.v1.Identifier;

import org.dataone.service.types.v1.SystemMetadata;

import com.hazelcast.core.IMap;

	private static Log log = LogFactory.getLog(SystemMetadataEventListener.class);

        // get shared structures and add listener

        IMap<Identifier, String> objectPathMap = DistributedMapsFactory.getObjectPathMap();

        log.info("Object path size:" + objectPathMap.size());

    }

     */

    public void stop() throws FileNotFoundException, ServiceFailure {

    	log.info("stopping index entry listener...");

    }

    /**

        return obsoletes;

    }

		// remove from the index

		try {

			solrIndex.remove(pid.getValue());

		} catch (Exception e) {

	}

	    //System.out.println("===================================calling entryUpdated method ");

	    log.info("===================================calling entryUpdated method ");

		// add to the index

		//System.out.println("===================================update the document "+pid.getValue());

		log.info("===================================update the document "+pid.getValue());

		Identifier obsoletes = systemMetadata.getObsoletes();

		List<String> obsoletesChain = null;

		if (obsoletes != null) {

#If the inerval is less than 0, the thread would not run.

index.regenerate.interval=7200000

index.evenlog.classname=edu.ucsb.nceas.metacat.index.event.IndexEventFileLog

############# SOLR Search Section ###########################################

#Embedded (default):

            	sysMeta.setArchived(true);

            	sysMeta.setDateSysMetadataModified(Calendar.getInstance().getTime());

				HazelcastService.getInstance().getSystemMetadataMap().put(guid, sysMeta);

            }

            // clear cache after inserting or updating a document

                    // save it to the map

                    HazelcastService.getInstance().getSystemMetadataMap().put(sysMeta.getIdentifier(), sysMeta);

                  } catch ( McdbDocNotFoundException dnfe ) {

                    logMetacat.debug(

                      "There was a problem finding the localId " +

					        // manage it in the store

                            HazelcastService.getInstance().getSystemMetadataMap().put(sm.getIdentifier(), sm);

                        } catch (Exception ee) {

                            // If the file did not exist before this method was 

            // update the local copy of system metadata for the pid

            try {

                HazelcastService.getInstance().getSystemMetadataMap().put(newSysMeta.getIdentifier(), newSysMeta);

                logMetacat.info("Updated local copy of system metadata for pid " +

                    pid.getValue() + " after change notification from the CN.");

    // save the sysmeta

    try {

    	HazelcastService.getInstance().getSystemMetadataMap().put(sysmeta.getIdentifier(), sysmeta);

    } catch (Exception e) {

    	logMetacat.error("Problem creating system metadata: " + pid.getValue(), e);

        throw new ServiceFailure("1190", e.getMessage());

      try {

        // note: the calling subclass handles the map hazelcast lock/unlock

      	HazelcastService.getInstance().getSystemMetadataMap().put(sysmeta.getIdentifier(), sysmeta);

      } catch (Exception e) {

          throw new ServiceFailure("1190", e.getMessage());

        try {

            HazelcastService.getInstance().getSystemMetadataMap().lock(sysMeta.getIdentifier());

            HazelcastService.getInstance().getSystemMetadataMap().put(sysMeta.getIdentifier(), sysMeta);

        } catch (Exception e) {

            throw new ServiceFailure("4862", e.getMessage());

              sysMeta.setArchived(true);

              sysMeta.setDateSysMetadataModified(Calendar.getInstance().getTime());

              HazelcastService.getInstance().getSystemMetadataMap().put(pid, sysMeta);

          } catch (McdbDocNotFoundException e) {

              throw new NotFound("1340", "The provided identifier was invalid.");

import org.apache.log4j.Logger;

import org.dataone.service.exceptions.InvalidSystemMetadata;

import org.dataone.service.types.v1.Identifier;

import org.dataone.service.types.v1.SystemMetadata;

import com.hazelcast.config.Config;

  /* The Hazelcast distributed missing identifiers set */

  private ISet<Identifier> missingIdentifiers;

  private HazelcastInstance hzInstance;

      missingIdentifiers.addItemListener(this, true);

      // Listen for changes to the system metadata map

      systemMetadata.addEntryListener(this, true);

  }

  /**

   * When Metacat changes the underlying store, we need to refresh the

   * in-memory representation of it.

   * @param guid

      	  // save the system metadata

    	  logReplication.debug("Saving SystemMetadata to shared map: " + sysMeta.getIdentifier().getValue());

      	  HazelcastService.getInstance().getSystemMetadataMap().put(sysMeta.getIdentifier(), sysMeta);

      }

      docinfoParser.parse(new InputSource(new StringReader(docInfoStr)));

    	  }

    	  // save the system metadata

    	  HazelcastService.getInstance().getSystemMetadataMap().put(sysMeta.getIdentifier(), sysMeta);

      }

								new ByteArrayInputStream(systemMetadataXML

										.getBytes("UTF-8")));

				HazelcastService.getInstance().getSystemMetadataMap().put(sysMeta.getIdentifier(), sysMeta);

			}

			logReplication.info("ReplicationHandler.handleSystemMetadata - Successfully replicated system metadata for guid: "

		      	}

				// save the system metadata

				HazelcastService.getInstance().getSystemMetadataMap().put(sysMeta.getIdentifier(), sysMeta);

			}

			// dates

	      	  }

	      	  // save the system metadata

	      	  HazelcastService.getInstance().getSystemMetadataMap().put(sysMeta.getIdentifier(), sysMeta);

	        }

	        // process the access control

							SystemMetadata.class,

							new ByteArrayInputStream(systemMetadataXML.getBytes("UTF-8")));

				HazelcastService.getInstance().getSystemMetadataMap().put(sysMeta.getIdentifier(), sysMeta);

			}

			logReplication.info("ReplicationService.handleForceReplicateSystemMetadataRequest - processed guid: " + guid);