Metacat

        suite.addTest(new ReplicationTest("testReplicateDataLocking"));

	public void testReplicateDataLocking() {

		try {

			// the id

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

			String docid = baseDocid + "." + 1;

			// the test data

			String object = "test";

			// insert data locally

			m.login(username, password);

			m.upload(docid, "testObject", IOUtils.toInputStream(object, MetaCatServlet.DEFAULT_ENCODING), object.getBytes(MetaCatServlet.DEFAULT_ENCODING).length);

			// 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(object, replicatedObject);

			// update the object on the target

			docid = baseDocid + "." + 2;

			object = "test2";

			targetMetacat.upload(docid, "testObject", IOUtils.toInputStream(object, MetaCatServlet.DEFAULT_ENCODING), object.getBytes(MetaCatServlet.DEFAULT_ENCODING).length);

			// wait for replication (forced)

			Thread.sleep(forceReplicationSleep);

			// check the original has the result

			is = m.read(docid);

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

			assertEquals(object, replicatedObject);

			// delete the object

			targetMetacat.delete(docid);

			// wait for replication (forced)

			Thread.sleep(forceReplicationSleep);

			// check that it is missing

			replicatedObject = null;

			try {

	    		is = m.read(docid);

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

			} catch (DocumentNotFoundException dnfe) {

				// expect this

				assertTrue(true);

			}

			assertNull(replicatedObject);

		} catch (Exception e) {

			e.printStackTrace();

			fail(e.getMessage());

		}

	}