Metacat

	 * Implement the EntryListener interface for Hazelcast, reponding to entry

	 * added events in the hzSystemMetadata map. Evaluate the entry and create

	 * CNReplicationTasks as appropriate (for DATA, METADATA, RESOURCE)

	 * 

	 * @param event - The EntryEvent that occurred

	 */

	@Override

	public void entryAdded(EntryEvent<Identifier, SystemMetadata> event) {

		logMetacat.debug("Entry added to System Metadata map: " + event.getKey().getValue());

		PartitionService partitionService = Hazelcast.getPartitionService();

		Partition partition = partitionService.getPartition(event.getKey());

		Member ownerMember = partition.getOwner();

		if (!ownerMember.localMember()) {

			// need to pull the entry into the local store

			logMetacat.debug("Saving entry locally: " + event.getKey().getValue());

			try {

				if (!IdentifierManager.getInstance().identifierExists(event.getKey().getValue())) {

					IdentifierManager.getInstance().createSystemMetadata(event.getValue());

				} else {

					IdentifierManager.getInstance().updateSystemMetadata(event.getValue());

				}

			} catch (McdbDocNotFoundException e) {

				logMetacat.error(

						"Could not save System Metadata to local store.", e);

			}

		// TODO evaluate the type of system metadata change, decide if it

		// warrants

		// a replication event, what type (DATA, METADATA, RESOURCE),

		// iteratively lock the PID, create and submit the tasks, and expect a

		// result back.

		// Deal with exceptions.

		boolean isMetadata = D1NodeService.isScienceMetadata(event.getValue());

		// TODO: do we need to do anything explicit here?

	}