Metacat

import java.io.StringReader;

    public void testReplicateEML_AtoB() {

    	try {

    		// the id

    		String baseDocid = DocumentUtil.generateDocumentId("replicationTest", 0);

    		String docid = baseDocid + "." + 1;

    		// the test data, no public access

    		String emlContent = null;

			emlContent = getTestEmlDoc(

    				"Test replication", //title, 

    				EML2_1_0, //emlVersion, 

    				null, //inlineData1, 

    				null, //inlineData2, 

    				null, //onlineUrl1, 

    				null, //onlineUrl2, 

    				null, //docAccessBlock , 

    				null, //inlineAccessBlock1, 

    				null, //inlineAccessBlock2, 

    				null, //onlineAccessBlock1, 

    				null //onlineAccessBlock2

    				);

    		StringReader xmlReader = new StringReader(emlContent);

			// insert data locally

    		m.login(username, password);

    		m.insert(docid, xmlReader, null);

    		// wait for replication (forced)

    		Thread.sleep(forceReplicationSleep);

    		// check the target for the same data

    		targetMetacat.login(username, password);

    		InputStream is = targetMetacat.read(docid);

    		String replicatedObject = IOUtils.toString(is, MetaCatServlet.DEFAULT_ENCODING);

    		assertEquals(emlContent, replicatedObject);

    		// update the object

    		docid = baseDocid + "." + 2;

    		//emlContent = getTestEmlDoc("Test replication2", EML2_1_0);

    		emlContent = getTestEmlDoc(

    				"Test replication", //title, 

    				EML2_1_0, //emlVersion, 

    				null, //inlineData1, 

    				null, //inlineData2, 

    				null, //onlineUrl1, 

    				null, //onlineUrl2, 

    				null, //docAccessBlock , 

    				null, //inlineAccessBlock1, 

    				null, //inlineAccessBlock2, 

    				null, //onlineAccessBlock1, 

    				null //onlineAccessBlock2

    				);

    		xmlReader = new StringReader(emlContent);

    		m.update(docid, xmlReader, null);

    		// wait for replication (forced)

    		Thread.sleep(forceReplicationSleep);

    		// check the target for the updated data

    		is = targetMetacat.read(docid);

    		replicatedObject = IOUtils.toString(is, MetaCatServlet.DEFAULT_ENCODING);

    		assertEquals(emlContent, replicatedObject);

    		// update the access control rules

    		m.setAccess(

    				docid, 

    				AccessControlInterface.PUBLIC, 

    				AccessControlInterface.READSTRING, 

    				AccessControlInterface.ALLOW, 

    				AccessControlInterface.ALLOWFIRST);

    		// wait for replication (forced)

    		Thread.sleep(forceReplicationSleep);

    		// check the target for the same data, logout to act as public

    		targetMetacat.logout();

    		is = targetMetacat.read(docid);

    		replicatedObject = IOUtils.toString(is, MetaCatServlet.DEFAULT_ENCODING);

    		assertEquals(emlContent, replicatedObject);

    	} catch (Exception e) {

    		e.printStackTrace();

			fail(e.getMessage());

		}

    }