Open Source Document Management System | OpenKM

2011-02-18 14:30:00,418 ERROR [org.apache.jackrabbit.core.XASessionImpl] Resource already associated with a transaction.
2011-02-18 14:30:00,418 ERROR [STDERR] javax.transaction.xa.XAException

imports...

public class VersionActionHandler implements ActionHandler{
	
	private static final long serialVersionUID = 1L;
	private static Log log = LogFactory.getLog(VersionActionHandler.class);
    
	public void execute(ExecutionContext context) throws Exception {
		String sTarea = context.getTask().getName();
		
		String actorId = context.getTaskInstance().getActorId();
		System.out.println("MAFE TASKINSTANCE actorId: " + actorId);

		JcrSessionManager sessionManager = JcrSessionManager.getInstance();
		DirectDocumentModule docModule = DirectDocumentModule.class.newInstance();
		DirectPropertyGroupModule pgModule = DirectPropertyGroupModule.class.newInstance();
		
		String uuid = (String)context.getContextInstance().getVariable("uuid");
		
		Map sessions = sessionManager.getSessions(); //AQUI DEVUELVO TODAS LAS SESIONES DISPONIBLES
		JcrSessionInfo info = null;
		Session session = null;
		String token = "";
		
		Iterator it = sessions.entrySet().iterator();
		while (it.hasNext()) {
			Map.Entry e = (Map.Entry)it.next();
			info = (JcrSessionInfo)e.getValue();
			token = String.valueOf(e.getKey());
			session = info.getSession(); //SOLO ME DEVUELVE LA SESION RELACIONADA AL USUARIO "system"
		}
		
		String path = docModule.getPath(token, uuid);
		Document doc = docModule.getProperties(session, path);
		InputStream is = docModule.getContent(token, path, false);
		
		String sComment = "Versionado por " + actorId + " en la tarea " + sTarea;
		String destino = "/okm:root/SISTEMAS/SAP/";
		String sfile = FileUtils.getName(doc.getPath());
		
		Document dfinal = null;
		try {
			dfinal = docModule.getProperties(session, destino + sfile);
		}catch(PathNotFoundException pnfe){}
		
		try {
			if (dfinal != null) {
				destino += sfile;
				docModule.checkout(token, destino);
				docModule.setContent(token, destino, is);
				docModule.checkin(token, destino, sComment);
			}else{
				dfinal = new Document();
				destino += sfile;
				dfinal.setPath(destino);
				dfinal.setMimeType(doc.getMimeType());
				dfinal.setAuthor(doc.getAuthor());
				dfinal.setCategories(doc.getCategories());
				dfinal.setKeywords(doc.getKeywords());
				dfinal.setNotes(doc.getNotes());
				dfinal.setSubscriptors(doc.getSubscriptors());
				dfinal.setPermissions(doc.getPermissions());
				docModule.create(token, dfinal, is);
			}
			context.getContextInstance().setVariable("okpub", "1");
			
		}catch(RepositoryException re){
			context.getContextInstance().setVariable("okpub", "0");
			re.printStackTrace();
		}catch(LockException le) {
			context.getContextInstance().setVariable("okpub", "0");
			le.printStackTrace();
		}catch(Exception e) {
			context.getContextInstance().setVariable("okpub", "0");
			throw e;
		}
	}
}