Wrapping a binary into cq:Page and reverse replicate it

TestServlet.java
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.Calendar;
import javax.jcr.Node;
import javax.jcr.Property;
import javax.jcr.RepositoryException;
import javax.jcr.Session;
import javax.jcr.ValueFactory;
import org.apache.felix.scr.annotations.Reference;
import org.apache.felix.scr.annotations.sling.SlingServlet;
import org.apache.jackrabbit.commons.JcrUtils;
import org.apache.sling.api.SlingHttpServletRequest;
import org.apache.sling.api.SlingHttpServletResponse;
import org.apache.sling.api.resource.LoginException;
import org.apache.sling.api.resource.ResourceResolver;
import org.apache.sling.api.resource.ResourceResolverFactory;
import org.apache.sling.api.servlets.SlingSafeMethodsServlet;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

@SlingServlet(paths = "/bin/test", extensions = "txt")
public class TestServlet extends SlingSafeMethodsServlet {
private static final Logger LOG = LoggerFactory.getLogger(TestServlet.class);

@Reference
private ResourceResolverFactory resolverFactory;
private static final String PARENT = "/content/usergenerated/content";

public void doGet(SlingHttpServletRequest request, SlingHttpServletResponse response) throws IOException {

ResourceResolver resourceResolver = null;

try {
resourceResolver = resolverFactory.getAdministrativeResourceResolver(null);
Session session = resourceResolver.adaptTo(Session.class);
reverseReplicateBinary(session, PARENT, "page123",
new ByteArrayInputStream("this is sample".getBytes()));
response.getWriter().println("session saved");
} catch (LoginException e) {
LOG.error("Can't get resolver", e);
} catch (RepositoryException e) {
LOG.error("Can't get resolver", e);
} finally {
if (resourceResolver != null) {
resourceResolver.close();
}
}
}

private void reverseReplicateBinary(Session session, String parentPath, String name, InputStream is)

throws RepositoryException {
ValueFactory valueFactory = session.getValueFactory();
Node parent = session.getNode(parentPath); Node page = JcrUtils.getOrCreateUniqueByPath(parent, name, "cq:Page");

Node jcrContent = page.addNode(Property.JCR_CONTENT, "cq:PageContent");
Node file = jcrContent.addNode("file", "nt:file");
Node resource = file.addNode(Property.JCR_CONTENT, "nt:resource");
resource.setProperty(Property.JCR_DATA, valueFactory.createBinary(is));
session.save(); jcrContent.setProperty("cq:lastModified", Calendar.getInstance());

jcrContent.setProperty("cq:lastModifiedBy", session.getUserID());
jcrContent.setProperty("cq:distribute", false);
session.save();

}
}