X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.support.jcr%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjcr%2Fexecution%2FJcrAgent.java;h=5febc792c44e9ce7b19a0a84428973b180c5863d;hb=fa15e0d0a70b92ba12153f5d5d02d7e900fc25d2;hp=a096e5d5eebd6aa84b93a8ff94a5c1b926846f10;hpb=0f05a24d55e92b847d2c72ff116ecd281a60adf8;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrAgent.java b/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrAgent.java index a096e5d5e..5febc792c 100644 --- a/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrAgent.java +++ b/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrAgent.java @@ -1,9 +1,25 @@ +/* + * Copyright (C) 2007-2012 Mathieu Baudier + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.argeo.slc.jcr.execution; import java.util.List; import java.util.UUID; import javax.jcr.Node; +import javax.jcr.Repository; import javax.jcr.RepositoryException; import javax.jcr.Session; @@ -21,7 +37,7 @@ import org.argeo.slc.runtime.SlcAgentFactory; /** SLC VM agent synchronizing with a JCR repository. */ public class JcrAgent extends DefaultAgent implements SlcAgentFactory, SlcNames { - private Session session; + private Repository repository; /** only one agent per VM is currently supported */ private final String agentNodeName = "default"; @@ -30,7 +46,9 @@ public class JcrAgent extends DefaultAgent implements SlcAgentFactory, SlcNames * LIFECYCLE */ protected String initAgentUuid() { + Session session = null; try { + session = repository.login(); Node vmAgentFactoryNode = JcrUtils.mkdirsSafe(session, SlcJcrConstants.VM_AGENT_FACTORY_PATH, SlcTypes.SLC_AGENT_FACTORY); @@ -46,11 +64,14 @@ public class JcrAgent extends DefaultAgent implements SlcAgentFactory, SlcNames } catch (RepositoryException e) { JcrUtils.discardQuietly(session); throw new SlcException("Cannot find JCR agent UUID", e); + } finally { + JcrUtils.logoutQuietly(session); } } - public void dispose() { - + @Override + public void destroy() { + super.destroy(); } /* @@ -88,12 +109,12 @@ public class JcrAgent extends DefaultAgent implements SlcAgentFactory, SlcNames /* * BEAN */ - public void setSession(Session session) { - this.session = session; - } - public String getAgentNodeName() { return agentNodeName; } + public void setRepository(Repository repository) { + this.repository = repository; + } + }