Metacat

      InputStream object = new ByteArrayInputStream("test".getBytes("UTF-8"));

      SystemMetadata sysmeta = createSystemMetadata(guid, session.getSubject(), object);

      Identifier newPid = new Identifier();

      Identifier pid = 

        MNodeService.getInstance(request).create(session, guid, object, sysmeta);

    			"The obsoletedBy field cannot have a value when creating entries.");

	}

    try {

      allowed = isAuthorized(session, pid, Permission.WRITE);

    } catch (NotFound e) {

      // The identifier doesn't exist, writing should be fine.

      allowed = true;

    }

    // verify checksum, only if we can reset the inputstream

        HazelcastService.getInstance().getSystemMetadataMap().unlock(pid);

    }

    // do we own it?

    for (Subject s: subjects) {

			// 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.

	}