You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@oodt.apache.org by bf...@apache.org on 2011/11/12 10:52:58 UTC
svn commit: r1201233 [1/3] - in /oodt/trunk/workflow: ./ src/main/assembly/
src/main/bin/ src/main/java/org/apache/oodt/cas/workflow/cli/
src/main/java/org/apache/oodt/cas/workflow/cli/action/
src/main/java/org/apache/oodt/cas/workflow/system/ src/main...
Author: bfoster
Date: Sat Nov 12 09:52:57 2011
New Revision: 1201233
URL: http://svn.apache.org/viewvc?rev=1201233&view=rev
Log:
- Integrated cas-cli
- several unit-tests to insure the actions invoke the correct them via the client and with the correct arguments
- fixed broken unit-test (hopefully stops jenkins from complaining about broken build)
Added:
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/DynWorkflowCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetConditionByIdCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetFirstPageCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetLastPageCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetNextPageCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetPrevPageCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetRegisteredEventsCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskByIdCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskWallClockTimeCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWallClockTimeCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowByIdCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstMetCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstsCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/PauseWorkflowInstCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/ResumeWorkflowInstCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/SendEventCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/StopWorkflowInstCliAction.java (with props)
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/WorkflowCliAction.java (with props)
oodt/trunk/workflow/src/main/resources/cmd-line-actions.xml (with props)
oodt/trunk/workflow/src/main/resources/cmd-line-options.xml (with props)
oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/cli/
oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/cli/TestWorkflowCli.java (with props)
oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/cli/UseMockClientCmdLineActionStore.java (with props)
oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/repository/MockWorkflowRepository.java (with props)
oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/system/MockXmlRpcWorkflowManagerClient.java (with props)
Modified:
oodt/trunk/workflow/pom.xml
oodt/trunk/workflow/src/main/assembly/assembly.xml
oodt/trunk/workflow/src/main/bin/wmgr-client
oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/system/XmlRpcWorkflowManagerClient.java
oodt/trunk/workflow/src/main/resources/logging.properties
oodt/trunk/workflow/src/main/resources/workflow.properties
oodt/trunk/workflow/src/test/org/apache/oodt/cas/workflow/system/TestXmlRpcWorkflowManagerClient.java
Modified: oodt/trunk/workflow/pom.xml
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/pom.xml?rev=1201233&r1=1201232&r2=1201233&view=diff
==============================================================================
--- oodt/trunk/workflow/pom.xml (original)
+++ oodt/trunk/workflow/pom.xml Sat Nov 12 09:52:57 2011
@@ -126,6 +126,11 @@ the License.
</dependency>
<dependency>
<groupId>org.apache.oodt</groupId>
+ <artifactId>cas-cli</artifactId>
+ <version>${project.parent.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.oodt</groupId>
<artifactId>cas-metadata</artifactId>
<version>${project.parent.version}</version>
</dependency>
Modified: oodt/trunk/workflow/src/main/assembly/assembly.xml
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/assembly/assembly.xml?rev=1201233&r1=1201232&r2=1201233&view=diff
==============================================================================
--- oodt/trunk/workflow/src/main/assembly/assembly.xml (original)
+++ oodt/trunk/workflow/src/main/assembly/assembly.xml Sat Nov 12 09:52:57 2011
@@ -55,6 +55,14 @@ the License.
</includes>
</fileSet>
<fileSet>
+ <directory>${basedir}/src/main/resources</directory>
+ <outputDirectory>policy</outputDirectory>
+ <includes>
+ <include>cmd-line-actions.xml</include>
+ <include>cmd-line-options.xml</include>
+ </includes>
+ </fileSet>
+ <fileSet>
<directory>${basedir}/src/main/resources/examples</directory>
<outputDirectory>policy</outputDirectory>
<excludes/>
Modified: oodt/trunk/workflow/src/main/bin/wmgr-client
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/bin/wmgr-client?rev=1201233&r1=1201232&r2=1201233&view=diff
==============================================================================
--- oodt/trunk/workflow/src/main/bin/wmgr-client (original)
+++ oodt/trunk/workflow/src/main/bin/wmgr-client Sat Nov 12 09:52:57 2011
@@ -23,4 +23,9 @@ fi
export JAVA_HOME
-$JAVA_HOME/bin/java -Djava.ext.dirs=../lib -Djava.util.logging.config.file=../etc/logging.properties org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient $*
+$JAVA_HOME/bin/java \
+ -Djava.ext.dirs=../lib \
+ -Djava.util.logging.config.file=../etc/logging.properties \
+ -Dorg.apache.oodt.cas.cli.action.spring.config=../policy/cmd-line-actions.xml \
+ -Dorg.apache.oodt.cas.cli.option.spring.config=../policy/cmd-line-options.xml \
+ org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient $*
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/DynWorkflowCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/DynWorkflowCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/DynWorkflowCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/DynWorkflowCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,69 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.util.List;
+
+//Apache imports
+import org.apache.commons.lang.Validate;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.metadata.Metadata;
+
+/**
+ * A {@link CmdLineAction} for submitting dynamically created {@link Workflow}s
+ * of pre-defined {@link WorkflowTask}s.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class DynWorkflowCliAction extends WorkflowCliAction {
+
+ private List<String> taskIds;
+ private Metadata metadata;
+
+ public DynWorkflowCliAction() {
+ metadata = new Metadata();
+ }
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ Validate.notNull(taskIds, "Must specify taskIds");
+
+ try {
+ String instId = getClient().executeDynamicWorkflow(taskIds, metadata);
+ System.out.println("Started dynamic workflow with id '" + instId + "'");
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to submit dynamic workflow for taskIds " + taskIds
+ + " with metadata " + metadata.getHashtable() + " : "
+ + e.getMessage(), e);
+ }
+ }
+
+ public void setTaskIds(List<String> taskIds) {
+ this.taskIds = taskIds;
+ }
+
+ public void addMetadata(List<String> metadata) {
+ Validate.isTrue(metadata.size() > 1);
+
+ this.metadata.addMetadata(metadata.get(0),
+ metadata.subList(1, metadata.size()));
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/DynWorkflowCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetConditionByIdCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetConditionByIdCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetConditionByIdCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetConditionByIdCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.WorkflowCondition;
+
+/**
+ * A {@link CmdLineAction} which retrieves WorkflowCondition information for
+ * WorkflowCondition with given condition ID.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetConditionByIdCliAction extends WorkflowCliAction {
+
+ private String conditionId;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ WorkflowCondition condition = getClient()
+ .getConditionById(conditionId);
+ System.out.println("Condition: [id=" + condition.getConditionId()
+ + ", name=" + condition.getConditionName() + ", order="
+ + condition.getOrder() + ", class="
+ + condition.getClass().getName() + "]");
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get condition by id for conditionId '" + conditionId
+ + "' : " + e.getMessage(), e);
+ }
+ }
+
+ public void setConditionId(String conditionId) {
+ this.conditionId = conditionId;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetConditionByIdCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetFirstPageCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetFirstPageCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetFirstPageCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetFirstPageCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.util.List;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.WorkflowInstance;
+import org.apache.oodt.cas.workflow.structs.WorkflowInstancePage;
+import org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient;
+
+/**
+ * Gets the first page of workflow instances.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetFirstPageCliAction extends WorkflowCliAction {
+
+ private String status;
+
+ @SuppressWarnings("unchecked")
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ XmlRpcWorkflowManagerClient client = getClient();
+ WorkflowInstancePage page = null;
+ if (status != null && !status.equals("")) {
+ page = client.paginateWorkflowInstances(1, status);
+ } else {
+ page = client.getFirstPage();
+ }
+
+ System.out.println("Page: [num=" + page.getPageNum() + ","
+ + "pageSize=" + page.getPageSize() + ",totalPages="
+ + page.getTotalPages() + "]");
+ if (page.getPageWorkflows() == null) {
+ throw new Exception(
+ "WorkflowManager returned null page of workflows");
+ }
+ for (WorkflowInstance inst : (List<WorkflowInstance>) page
+ .getPageWorkflows()) {
+ System.out.println("Instance: [id=" + inst.getId() + ", status="
+ + inst.getStatus() + ", currentTask="
+ + inst.getCurrentTaskId() + ", workflow="
+ + inst.getWorkflow().getName() + ", wallClockTime="
+ + client.getWorkflowWallClockMinutes(inst.getId())
+ + ", currentTaskWallClockTime="
+ + client.getWorkflowCurrentTaskWallClockMinutes(inst.getId())
+ + "]");
+ }
+
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get first page of workflows : " + e.getMessage(), e);
+ }
+ }
+
+ public void setStatus(String status) {
+ this.status = status;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetFirstPageCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetLastPageCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetLastPageCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetLastPageCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetLastPageCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,80 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.util.List;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.WorkflowInstance;
+import org.apache.oodt.cas.workflow.structs.WorkflowInstancePage;
+import org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient;
+
+/**
+ * A {@link CmdLineOption} which gets the last page of workflows.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetLastPageCliAction extends WorkflowCliAction {
+
+ private String status;
+
+ @SuppressWarnings("unchecked")
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ XmlRpcWorkflowManagerClient client = getClient();
+ WorkflowInstancePage page = null;
+ if (status != null && !status.equals("")) {
+ WorkflowInstancePage firstPage = client.paginateWorkflowInstances(
+ 1, status);
+ page = client.paginateWorkflowInstances(firstPage.getTotalPages(),
+ status);
+ } else {
+ page = client.getLastPage();
+ }
+
+ System.out.println("Page: [num=" + page.getPageNum() + ","
+ + "pageSize=" + page.getPageSize() + ",totalPages="
+ + page.getTotalPages() + "]");
+ if (page.getPageWorkflows() == null) {
+ throw new Exception(
+ "WorkflowManager returned null page of workflows");
+ }
+ for (WorkflowInstance inst : (List<WorkflowInstance>) page
+ .getPageWorkflows()) {
+ System.out.println("Instance: [id=" + inst.getId() + ", status="
+ + inst.getStatus() + ", currentTask="
+ + inst.getCurrentTaskId() + ", workflow="
+ + inst.getWorkflow().getName() + ",wallClockTime="
+ + client.getWorkflowWallClockMinutes(inst.getId())
+ + ",currentTaskWallClockTime="
+ + client.getWorkflowCurrentTaskWallClockMinutes(inst.getId())
+ + "]");
+ }
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get last page of workflows with " + "status '"
+ + status + "' : " + e.getMessage(), e);
+ }
+ }
+
+ public void setStatus(String status) {
+ this.status = status;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetLastPageCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetNextPageCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetNextPageCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetNextPageCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetNextPageCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,87 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.util.List;
+
+//Apache imports
+import org.apache.commons.lang.Validate;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.WorkflowInstance;
+import org.apache.oodt.cas.workflow.structs.WorkflowInstancePage;
+import org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient;
+
+/**
+ * A {@link CmdLineAction} which gets the next page of workflows.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetNextPageCliAction extends WorkflowCliAction {
+
+ private int pageNum = -1;
+ private String status;
+
+ @SuppressWarnings("unchecked")
+ @Override
+ public void execute() throws CmdLineActionException {
+ Validate.isTrue(pageNum != -1);
+
+ try {
+ XmlRpcWorkflowManagerClient client = getClient();
+ WorkflowInstancePage page = null;
+ if (status != null && !status.equals("")) {
+ page = client.paginateWorkflowInstances(pageNum + 1, status);
+ } else {
+ page = client.paginateWorkflowInstances(pageNum + 1);
+ }
+
+ System.out.println("Page: [num=" + page.getPageNum() + ","
+ + "pageSize=" + page.getPageSize() + ",totalPages="
+ + page.getTotalPages() + "]");
+ if (page.getPageWorkflows() == null) {
+ throw new Exception(
+ "WorkflowManager returned null page of workflows");
+ }
+ for (WorkflowInstance inst : (List<WorkflowInstance>) page
+ .getPageWorkflows()) {
+ System.out.println("Instance: [id=" + inst.getId() + ", status="
+ + inst.getStatus() + ", currentTask="
+ + inst.getCurrentTaskId() + ", workflow="
+ + inst.getWorkflow().getName() + ",wallClockTime="
+ + client.getWorkflowWallClockMinutes(inst.getId())
+ + ",currentTaskWallClockTime="
+ + client.getWorkflowCurrentTaskWallClockMinutes(inst.getId())
+ + "]");
+ }
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get next page of workflows for page '" + pageNum
+ + "' and status '" + status + "' : " + e.getMessage(), e);
+ }
+ }
+
+ public void setPageNum(int pageNum) {
+ this.pageNum = pageNum;
+ }
+
+ public void setStatus(String status) {
+ this.status = status;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetNextPageCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetPrevPageCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetPrevPageCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetPrevPageCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetPrevPageCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,88 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.util.List;
+
+//Apache imports
+import org.apache.commons.lang.Validate;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.WorkflowInstance;
+import org.apache.oodt.cas.workflow.structs.WorkflowInstancePage;
+import org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient;
+
+/**
+ * A {@link CmdLineAction} which gets the previous page of workflows.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetPrevPageCliAction extends WorkflowCliAction {
+
+ private int pageNum = -1;
+ private String status;
+
+ @SuppressWarnings("unchecked")
+ @Override
+ public void execute() throws CmdLineActionException {
+ Validate.isTrue(pageNum != -1);
+
+ try {
+ XmlRpcWorkflowManagerClient client = getClient();
+ WorkflowInstancePage page = null;
+ if (status != null && !status.equals("")) {
+ page = client.paginateWorkflowInstances(pageNum - 1, status);
+ } else {
+ page = client.paginateWorkflowInstances(pageNum - 1);
+ }
+
+ System.out.println("Page: [num=" + page.getPageNum() + ","
+ + "pageSize=" + page.getPageSize() + ",totalPages="
+ + page.getTotalPages() + "]");
+ if (page.getPageWorkflows() == null) {
+ throw new Exception(
+ "WorkflowManager returned null page of workflows");
+ }
+ for (WorkflowInstance inst : (List<WorkflowInstance>) page
+ .getPageWorkflows()) {
+ System.out.println("Instance: [id=" + inst.getId() + ", status="
+ + inst.getStatus() + ", currentTask="
+ + inst.getCurrentTaskId() + ", workflow="
+ + inst.getWorkflow().getName() + ",wallClockTime="
+ + client.getWorkflowWallClockMinutes(inst.getId())
+ + ",currentTaskWallClockTime="
+ + client.getWorkflowCurrentTaskWallClockMinutes(inst.getId())
+ + "]");
+ }
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get previous page of workflows for " + "pageNum '"
+ + pageNum + "' and status '" + status + "' : "
+ + e.getMessage(), e);
+ }
+ }
+
+ public void setPageNum(int pageNum) {
+ this.pageNum = pageNum;
+ }
+
+ public void setStatus(String status) {
+ this.status = status;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetPrevPageCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetRegisteredEventsCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetRegisteredEventsCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetRegisteredEventsCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetRegisteredEventsCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.util.List;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+
+/**
+ * A {@link CmdLineAction} which gets a list of registered events.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetRegisteredEventsCliAction extends WorkflowCliAction {
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ @SuppressWarnings("unchecked")
+ List<String> events = getClient().getRegisteredEvents();
+
+ if (events == null) {
+ throw new Exception("WorkflowManager returned null event list");
+ }
+ for (String event : events) {
+ System.out.println("Event: [name=" + event + "]");
+ }
+ } catch (Exception e) {
+ throw new CmdLineActionException("Failed to get registered events : "
+ + e.getMessage(), e);
+ }
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetRegisteredEventsCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskByIdCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskByIdCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskByIdCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskByIdCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,52 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.WorkflowTask;
+
+/**
+ * A {@link CmdLineAction} which retrieves WorkflowTask information for
+ * WorkflowTask with given task ID.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetTaskByIdCliAction extends WorkflowCliAction {
+
+ private String taskId;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ WorkflowTask task = getClient().getTaskById(taskId);
+ System.out.println("Task: [id=" + task.getTaskId() + ", name="
+ + task.getTaskName() + ", order=" + task.getOrder() + ", class="
+ + task.getClass().getName() + ", numConditions="
+ + task.getConditions().size() + ", configuration="
+ + task.getTaskConfig().getProperties() + "]");
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get task by id for taskId '" + taskId + "' : "
+ + e.getMessage(), e);
+ }
+ }
+
+ public void setTaskId(String taskId) {
+ this.taskId = taskId;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskByIdCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskWallClockTimeCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskWallClockTimeCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskWallClockTimeCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskWallClockTimeCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+
+/**
+ * A {@link CmdLineAction} which get a workflow instance's current task's wall
+ * clock time.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetTaskWallClockTimeCliAction extends WorkflowCliAction {
+
+ private String instanceId;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ double wallClockTime = getClient()
+ .getWorkflowCurrentTaskWallClockMinutes(instanceId);
+ System.out.println(wallClockTime + " minutes");
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get current workflow instance's "
+ + "currents tasks wall clock time : " + e.getMessage(), e);
+ }
+ }
+
+ public void setInstanceId(String instanceId) {
+ this.instanceId = instanceId;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetTaskWallClockTimeCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWallClockTimeCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWallClockTimeCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWallClockTimeCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWallClockTimeCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,48 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+
+/**
+ * A {@link CmdLineAction} which gets Wall Clock Time for a given workflow
+ * instance.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetWallClockTimeCliAction extends WorkflowCliAction {
+
+ private String instanceId;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ double wallClockTime = getClient().getWorkflowWallClockMinutes(
+ instanceId);
+ System.out.println(wallClockTime + " minutes");
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get wall clock time for instance '" + instanceId
+ + "' : " + e.getMessage(), e);
+ }
+ }
+
+ public void setInstanceId(String instanceId) {
+ this.instanceId = instanceId;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWallClockTimeCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowByIdCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowByIdCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowByIdCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowByIdCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,50 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.Workflow;
+
+/**
+ * A {@link CmdLineAction} which retrieves Workflow information for
+ * Workflow with given workflow ID.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetWorkflowByIdCliAction extends WorkflowCliAction {
+
+ private String workflowId;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ Workflow workflow = getClient().getWorkflowById(workflowId);
+ System.out.println("Workflow: [id=" + workflow.getId() + ", name="
+ + workflow.getName() + ", numTasks="
+ + workflow.getTasks().size() + "]");
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get workflow information for" + " workflowId '"
+ + workflowId + "' : " + e.getMessage(), e);
+ }
+ }
+
+ public void setWorkflowId(String workflowId) {
+ this.workflowId = workflowId;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowByIdCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,62 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.WorkflowInstance;
+import org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient;
+
+/**
+ * A {@link CmdLineAction} which get WorkflowInstance information by given
+ * instanceId.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetWorkflowInstCliAction extends WorkflowCliAction {
+
+ private String instanceId;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ XmlRpcWorkflowManagerClient client = getClient();
+ WorkflowInstance inst = client.getWorkflowInstanceById(instanceId);
+ if (inst == null) {
+ throw new Exception(
+ "WorkflowManager returned null workflow instance");
+ }
+ System.out.println("Instance: [id=" + inst.getId() + ", status="
+ + inst.getStatus() + ", currentTask=" + inst.getCurrentTaskId()
+ + ", workflow=" + inst.getWorkflow().getName()
+ + ",wallClockTime="
+ + client.getWorkflowWallClockMinutes(inst.getId())
+ + ",currentTaskWallClockTime="
+ + client.getWorkflowCurrentTaskWallClockMinutes(inst.getId())
+ + "]");
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get workflow instance information for"
+ + " instanceId '" + instanceId + "' : " + e.getMessage(),
+ e);
+ }
+ }
+
+ public void setInstanceId(String instanceId) {
+ this.instanceId = instanceId;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstMetCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstMetCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstMetCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstMetCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,53 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//Apache imports
+import org.apache.commons.lang.Validate;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.metadata.Metadata;
+
+/**
+ * A {@link CmdLineAction} which get workflow instance metadata.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetWorkflowInstMetCliAction extends WorkflowCliAction {
+
+ private String instanceId;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ Validate.notNull(instanceId);
+
+ try {
+ Metadata met = getClient().getWorkflowInstanceMetadata(instanceId);
+ System.out.println("[id=" + instanceId + ", met=" + met.getHashtable()
+ + "]");
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get metadata for workflow instance '" + instanceId
+ + "' : " + e.getMessage(), e);
+ }
+ }
+
+ public void setInstanceId(String instanceId) {
+ this.instanceId = instanceId;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstMetCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstsCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstsCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstsCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstsCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,68 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.util.List;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.WorkflowInstance;
+import org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient;
+
+/**
+ * A {@link CmdLineAction} which lists workflow instances current managed by
+ * workflow manager at given URL.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetWorkflowInstsCliAction extends WorkflowCliAction {
+
+ @Override
+ public void execute() throws CmdLineActionException {
+
+ try {
+ XmlRpcWorkflowManagerClient client = getClient();
+ @SuppressWarnings("unchecked")
+ List<WorkflowInstance> insts = client.getWorkflowInstances();
+
+ if (insts == null) {
+ throw new Exception(
+ "WorkflowManager return null workflow instances list");
+ }
+ for (WorkflowInstance inst : insts) {
+ System.out.println("Instance: [id="
+ + inst.getId()
+ + ", status="
+ + inst.getStatus()
+ + ", currentTask="
+ + inst.getCurrentTaskId()
+ + ", workflow="
+ + inst.getWorkflow().getName()
+ + ",wallClockTime="
+ + client.getWorkflowWallClockMinutes(inst.getId())
+ + ",currentTaskWallClockTime="
+ + client.getWorkflowCurrentTaskWallClockMinutes(inst
+ .getId()) + "]");
+ }
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get workflow instances from URL '" + getUrl()
+ + "' : " + e.getMessage(), e);
+ }
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowInstsCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,60 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.util.List;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.Workflow;
+
+/**
+ * A {@link CmdLineAction} which get the current list of workflows by
+ * event name
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetWorkflowsByEventCliAction extends WorkflowCliAction {
+
+ private String eventName;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ @SuppressWarnings("unchecked")
+ List<Workflow> workflows = getClient().getWorkflowsByEvent(eventName);
+
+ if (workflows == null) {
+ throw new Exception("WorkflowManager returned null workflow list");
+ }
+ for (Workflow workflow : workflows) {
+ System.out.println("Workflow: [id=" + workflow.getId() + ", name="
+ + workflow.getName() + ", numTasks="
+ + workflow.getTasks().size() + "]");
+ }
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get workflows by event name '" + eventName + "' : "
+ + e.getMessage(), e);
+ }
+ }
+
+ public void setEventName(String eventName) {
+ this.eventName = eventName;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsByEventCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.util.List;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.workflow.structs.Workflow;
+
+/**
+ * A {@link CmdLineAction} which get list of know workflow models from
+ * WorkflowManager at given URL.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class GetWorkflowsCliAction extends WorkflowCliAction {
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ @SuppressWarnings("unchecked")
+ List<Workflow> workflows = getClient().getWorkflows();
+
+ if (workflows == null) {
+ throw new Exception(
+ "WorkflowManager returned null list of Workflows");
+ }
+
+ for (Workflow workflow : workflows) {
+ System.out.println("Workflow: [id=" + workflow.getId() + ", name="
+ + workflow.getName() + ", numTasks="
+ + workflow.getTasks().size() + "]");
+ }
+ } catch (Exception e) {
+ throw new CmdLineActionException(
+ "Failed to get list of workflow models from url '" + getUrl()
+ + "' : " + e.getMessage(), e);
+ }
+ }
+
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/GetWorkflowsCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/PauseWorkflowInstCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/PauseWorkflowInstCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/PauseWorkflowInstCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/PauseWorkflowInstCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+
+/**
+ * A {@link CmdLineAction} which stops a workflow instance.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class PauseWorkflowInstCliAction extends WorkflowCliAction {
+
+ private String instanceId;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ if (getClient().pauseWorkflowInstance(instanceId)) {
+ System.out.println("Successfully paused workflow '" + instanceId
+ + "'");
+ } else {
+ throw new Exception("Paused workflow returned false");
+ }
+ } catch (Exception e) {
+ throw new CmdLineActionException("Failed to pause workflow '"
+ + instanceId + "' : " + e.getMessage(), e);
+ }
+ }
+
+ public void setInstanceId(String instanceId) {
+ this.instanceId = instanceId;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/PauseWorkflowInstCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/ResumeWorkflowInstCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/ResumeWorkflowInstCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/ResumeWorkflowInstCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/ResumeWorkflowInstCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+
+/**
+ * A {@link CmdLineAction} which resumes a paused workflow instance.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class ResumeWorkflowInstCliAction extends WorkflowCliAction {
+
+ private String instanceId;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ if (getClient().resumeWorkflowInstance(instanceId)) {
+ System.out.println("Successfully resumed workflow '" + instanceId
+ + "'");
+ } else {
+ throw new Exception("Resume workflow returned false");
+ }
+ } catch (Exception e) {
+ throw new CmdLineActionException("Failed to resume workflow '"
+ + instanceId + "' : " + e.getMessage(), e);
+ }
+ }
+
+ public void setInstanceId(String instanceId) {
+ this.instanceId = instanceId;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/ResumeWorkflowInstCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/SendEventCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/SendEventCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/SendEventCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/SendEventCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,72 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.util.List;
+
+//Apache imports
+import org.apache.commons.lang.Validate;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+import org.apache.oodt.cas.metadata.Metadata;
+
+/**
+ * A {@link CmdLineAction} which triggers a workflow event.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class SendEventCliAction extends WorkflowCliAction {
+
+ private String eventName;
+ private Metadata metadata;
+
+ public SendEventCliAction() {
+ metadata = new Metadata();
+ }
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ Validate.notNull(eventName, "Must specify eventName");
+
+ try {
+ System.out.print("Sending event '" + eventName + "'... ");
+ System.out.println(getClient().sendEvent(eventName, metadata) ?
+ "SUCCESS" : "FAILURE");
+ } catch (Exception e) {
+ throw new CmdLineActionException("Failed to send event '" + eventName
+ + "' to url '" + getUrl() + "' with metadata '"
+ + metadata.getHashtable() + "' : " + e.getMessage(), e);
+ }
+ }
+
+ public void setEventName(String eventName) {
+ this.eventName = eventName;
+ }
+
+ public String getEventName() {
+ return eventName;
+ }
+
+ public void addMetadata(List<String> metadata) {
+ Validate.isTrue(metadata.size() > 1);
+
+ this.metadata.addMetadata(metadata.get(0),
+ metadata.subList(1, metadata.size()));
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/SendEventCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/StopWorkflowInstCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/StopWorkflowInstCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/StopWorkflowInstCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/StopWorkflowInstCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,49 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//OODT imports
+import org.apache.oodt.cas.cli.exception.CmdLineActionException;
+
+/**
+ * A {@link CmdLineAction} which stops a workflow instance.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public class StopWorkflowInstCliAction extends WorkflowCliAction {
+
+ private String instanceId;
+
+ @Override
+ public void execute() throws CmdLineActionException {
+ try {
+ if (getClient().stopWorkflowInstance(instanceId)) {
+ System.out.println("Successfully stopped workflow '" + instanceId
+ + "'");
+ } else {
+ throw new Exception("Stop workflow returned false");
+ }
+ } catch (Exception e) {
+ throw new CmdLineActionException("Failed to stop workflow '"
+ + instanceId + "' : " + e.getMessage(), e);
+ }
+ }
+
+ public void setInstanceId(String instanceId) {
+ this.instanceId = instanceId;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/StopWorkflowInstCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Added: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/WorkflowCliAction.java
URL: http://svn.apache.org/viewvc/oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/WorkflowCliAction.java?rev=1201233&view=auto
==============================================================================
--- oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/WorkflowCliAction.java (added)
+++ oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/WorkflowCliAction.java Sat Nov 12 09:52:57 2011
@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You 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.apache.oodt.cas.workflow.cli.action;
+
+//JDK imports
+import java.net.MalformedURLException;
+import java.net.URL;
+
+//Apache imports
+import org.apache.commons.lang.Validate;
+
+//OODT imports
+import org.apache.oodt.cas.cli.action.CmdLineAction;
+import org.apache.oodt.cas.workflow.system.XmlRpcWorkflowManagerClient;
+
+/**
+ * Base {@link CmdLineAction} for Workflow Manager.
+ *
+ * @author bfoster (Brian Foster)
+ */
+public abstract class WorkflowCliAction extends CmdLineAction {
+
+ private XmlRpcWorkflowManagerClient client;
+
+ public String getUrl() {
+ return System.getProperty("org.apache.oodt.cas.workflow.url");
+ }
+
+ protected XmlRpcWorkflowManagerClient getClient()
+ throws MalformedURLException {
+ Validate.notNull(getUrl());
+
+ if (client != null) {
+ return client;
+ } else {
+ return new XmlRpcWorkflowManagerClient(new URL(getUrl()));
+ }
+ }
+
+ public void setClient(XmlRpcWorkflowManagerClient client) {
+ this.client = client;
+ }
+}
Propchange: oodt/trunk/workflow/src/main/java/org/apache/oodt/cas/workflow/cli/action/WorkflowCliAction.java
------------------------------------------------------------------------------
svn:mime-type = text/plain
Re: svn commit: r1201233 [1/3] - in /oodt/trunk/workflow: ./
src/main/assembly/ src/main/bin/
src/main/java/org/apache/oodt/cas/workflow/cli/
src/main/java/org/apache/oodt/cas/workflow/cli/action/
src/main/java/org/apache/oodt/cas/workflow/system/ src/...
Posted by "Mattmann, Chris A (388J)" <ch...@jpl.nasa.gov>.
Thanks for fixing the unit tests dude!
Once I wrap up OPSUI, I'm going to wrap up OODT-310 and OODT-215, once and for all!
Cheers,
Chris
On Nov 12, 2011, at 1:52 AM, <bf...@apache.org> <bf...@apache.org> wrote:
> Author: bfoster
> Date: Sat Nov 12 09:52:57 2011
> New Revision: 1201233
>
> URL: http://svn.apache.org/viewvc?rev=1201233&view=rev
> Log:
> - Integrated cas-cli
> - several unit-tests to insure the actions invoke the correct them via the client and with the correct arguments
> - fixed broken unit-test (hopefully stops jenkins from complaining about broken build)
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Chris Mattmann, Ph.D.
Senior Computer Scientist
NASA Jet Propulsion Laboratory Pasadena, CA 91109 USA
Office: 171-266B, Mailstop: 171-246
Email: chris.a.mattmann@nasa.gov
WWW: http://sunset.usc.edu/~mattmann/
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
Adjunct Assistant Professor, Computer Science Department
University of Southern California, Los Angeles, CA 90089 USA
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++