X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.core%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fcore%2Fruntime%2FDefaultAgent.java;h=ca230856f4f2103f3288dfacf49cd52edb52d382;hb=548235484edd6b48de5ddc3bbca318e0e49cb57b;hp=141ccbe72cf2f3e6dfdd323da08170e2bc850aeb;hpb=8edbca70380f4c884f523073819fd915754185d2;p=gpl%2Fargeo-slc.git diff --git a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/runtime/DefaultAgent.java b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/runtime/DefaultAgent.java index 141ccbe72..ca230856f 100644 --- a/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/runtime/DefaultAgent.java +++ b/runtime/org.argeo.slc.core/src/main/java/org/argeo/slc/core/runtime/DefaultAgent.java @@ -1,25 +1,73 @@ +/* + * Copyright (C) 2010 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.core.runtime; +import java.net.InetAddress; +import java.net.UnknownHostException; import java.util.List; +import java.util.UUID; +import org.argeo.slc.SlcException; import org.argeo.slc.execution.ExecutionModuleDescriptor; import org.argeo.slc.execution.ExecutionModulesManager; import org.argeo.slc.process.SlcExecution; import org.argeo.slc.runtime.SlcAgent; +import org.argeo.slc.runtime.SlcAgentDescriptor; +/** Implements the base methods of an SLC agent. */ public class DefaultAgent implements SlcAgent { - // private final static Log log = LogFactory.getLog(AbstractAgent.class); - + private SlcAgentDescriptor agentDescriptor; private ExecutionModulesManager modulesManager; + /* + * LIFECYCLE + */ + public void init() { + try { + agentDescriptor = new SlcAgentDescriptor(); + agentDescriptor.setUuid(initAgentUuid()); + agentDescriptor.setHost(InetAddress.getLocalHost().getHostName()); + } catch (UnknownHostException e) { + throw new SlcException("Unable to create agent descriptor.", e); + } + } + + public void dispose() { + + } + + /** + * Called during initialization in order to determines the agent UUID. To be + * overridden. By default creates a new one per instance. + */ + protected String initAgentUuid() { + return UUID.randomUUID().toString(); + } + + /* + * SLC AGENT + */ public void runSlcExecution(final SlcExecution slcExecution) { modulesManager.process(slcExecution); } public ExecutionModuleDescriptor getExecutionModuleDescriptor( String moduleName, String version) { - return modulesManager.getExecutionModuleDescriptor(moduleName, - version); + return modulesManager.getExecutionModuleDescriptor(moduleName, version); } public List listExecutionModuleDescriptors() { @@ -30,12 +78,23 @@ public class DefaultAgent implements SlcAgent { return true; } + /* + * BEAN + */ public void setModulesManager(ExecutionModulesManager modulesManager) { this.modulesManager = modulesManager; } - public ExecutionModulesManager getModulesManager() { - return modulesManager; + protected SlcAgentDescriptor getAgentDescriptor() { + return agentDescriptor; } + public String getAgentUuid() { + return agentDescriptor.getUuid(); + } + + @Override + public String toString() { + return agentDescriptor.toString(); + } }