Metacat

package edu.ucsb.nceas.metacat.dataone;

import java.util.Map;

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

import org.junit.Before;

import org.junit.Test;

import com.hazelcast.core.Hazelcast;

import com.hazelcast.core.HazelcastInstance;

import edu.ucsb.nceas.MCTestCase;

public class HzObjectPathMapTest extends MCTestCase {

	@Before

	public void setUp() {

	}

	@Test

    public void testInstantiation() {

        // start a member

        HazelcastInstance h1 = Hazelcast.newHazelcastInstance(null);

        Map map1 = h1.getMap("hzObjectPath");

        assertEquals(99, map1.size());

	}

	@Test public void testProducerConsumer() {

		// start a member

		System.getProperties().setProperty("hazelcast.config",

				"/Users/rnahf/software/workspace/nceas/metacat/" +

				"test/edu/ucsb/nceas/metacat/dataone/hazelcast.test.properties.xml");

		HazelcastInstance h1 = Hazelcast.newHazelcastInstance(null);

		Map serverMap = h1.getMap("hzObjectPath");

		System.getProperties().setProperty("hazelcast.hzObjectPathRole","consumer");

		HazelcastInstance h2 = Hazelcast.newHazelcastInstance(null);

		Map clientMap = h2.getMap("hzObjectPath");

		System.out.println(serverMap.get(createIdentifier("testID.35")));

		System.out.println(serverMap.get(createIdentifier("testID.23434")));

		String pathValue = (String) clientMap.get(createIdentifier("testID.35"));

		System.out.println("pathValue: " + pathValue);

		assertEquals("/path/testID.35", pathValue);

	}	

	private Identifier createIdentifier(String idValue) {

		Identifier id = new Identifier();

		id.setValue(idValue);

		return id;

	}

}