Metacat

import java.io.FileInputStream;

import java.io.InputStream;

import org.apache.commons.logging.Log;

import org.apache.commons.logging.LogFactory;

import org.dataone.configuration.Settings;

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

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

import com.hazelcast.client.ClientConfig;

import com.hazelcast.client.HazelcastClient;

import com.hazelcast.core.EntryEvent;

import com.hazelcast.core.EntryListener;

import com.hazelcast.core.IMap;

public class SystemMetadataEventListener implements EntryListener<Identifier, SystemMetadata> {

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

	private SolrIndex solrIndex = null;

	private HazelcastClient hzClient;

    private IMap<Identifier, SystemMetadata> systemMetadataMap;

    private IMap<Identifier, String> objectPathMap;

    /**

     * Register this instance as a system metadata map event listener.

     */

    public void start() {

    	// get config values

        String hzSystemMetadata = Settings.getConfiguration().getString(

                "dataone.hazelcast.systemMetadata");

        String hzObjectPath = Settings.getConfiguration().getString(

                "dataone.hazelcast.objectPath");

        String hzGroupName = Settings.getConfiguration().getString(

                "dataone.hazelcast.groupName");

        String hzGroupPassword = Settings.getConfiguration().getString(

                "dataone.hazelcast.groupPassword");

        String hzAddress = Settings.getConfiguration().getString(

                "dataone.hazelcast.address");

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

    	log.info("System Metadata value: " + hzSystemMetadata);

    	log.info("Object path value: " + hzObjectPath);

    	log.info("Group Name: " + hzGroupName);

    	log.info("Group Password: " + "*****"); // don't show value

    	log.info("HZ Address: " + hzAddress);

    	// connect to the HZ cluster

        ClientConfig cc = new ClientConfig();

		cc.getGroupConfig().setName(hzGroupName);

		cc.getGroupConfig().setPassword(hzGroupPassword);

		cc.addAddress(hzAddress );

        try {

        	this.hzClient = HazelcastClient.newHazelcastClient(cc);

        } catch (Exception e) {

            log.error("Unable to create hazelcast client: ", e);

            e.printStackTrace();

        }

        // get shared structures and add listener

        this.systemMetadataMap = this.hzClient.getMap(hzSystemMetadata);

        this.objectPathMap = this.hzClient.getMap(hzObjectPath);

        this.systemMetadataMap.addEntryListener(this, true);

        log.info("System Metadata size: " + this.systemMetadataMap.size());

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

    }

    /**

     * Removes this instance as a system metadata map event listener.

     */

    public void stop() {

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

        this.systemMetadataMap.removeEntryListener(this);

    }

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

		// add to the index

		Identifier pid = entryEvent.getKey();

		SystemMetadata systemMetadata = entryEvent.getValue();

		String objectPath = objectPathMap.get(pid);

		InputStream data = null;

		try {

			data = new FileInputStream(objectPath);

			// TODO: pass the SM object

			solrIndex.insert(pid.getValue(), null, data);

		} catch (Exception e) {

			log.error(e.getMessage(), e);

		}

	}

	public void entryEvicted(EntryEvent<Identifier, SystemMetadata> entryEvent) {

		// TODO Auto-generated method stub

	}

	public void entryRemoved(EntryEvent<Identifier, SystemMetadata> entryEvent) {

		// TODO Auto-generated method stub

	}

	public void entryUpdated(EntryEvent<Identifier, SystemMetadata> entryEvent) {

		// TODO Auto-generated method stub

	}