From 0ed2c1124cf1b9e49a2ec1fa0126a8df09f9e758 Mon Sep 17 00:00:00 2001 From: Andrew Branson Date: Tue, 7 Oct 2014 09:18:11 +0200 Subject: Repackage to org.cristalise --- .../java/org/cristalise/kernel/events/History.java | 152 +++++++++++++++++++++ 1 file changed, 152 insertions(+) create mode 100644 src/main/java/org/cristalise/kernel/events/History.java (limited to 'src/main/java/org/cristalise/kernel/events/History.java') diff --git a/src/main/java/org/cristalise/kernel/events/History.java b/src/main/java/org/cristalise/kernel/events/History.java new file mode 100644 index 0000000..bca0fa8 --- /dev/null +++ b/src/main/java/org/cristalise/kernel/events/History.java @@ -0,0 +1,152 @@ +/** + * This file is part of the CRISTAL-iSE kernel. + * Copyright (c) 2001-2014 The CRISTAL Consortium. All rights reserved. + * + * This library is free software; you can redistribute it and/or modify it + * under the terms of the GNU Lesser General Public License as published + * by the Free Software Foundation; either version 3 of the License, or (at + * your option) any later version. + * + * This library is distributed in the hope that it will be useful, but WITHOUT + * ANY WARRANTY; with out even the implied warranty of MERCHANTABILITY or + * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public + * License for more details. + * + * You should have received a copy of the GNU Lesser General Public License + * along with this library; if not, write to the Free Software Foundation, + * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA. + * + * http://www.fsf.org/licensing/licenses/lgpl.html + */ +package org.cristalise.kernel.events; + + +import org.cristalise.kernel.common.InvalidDataException; +import org.cristalise.kernel.lifecycle.instance.stateMachine.Transition; +import org.cristalise.kernel.lookup.AgentPath; +import org.cristalise.kernel.lookup.ItemPath; +import org.cristalise.kernel.persistency.ClusterStorage; +import org.cristalise.kernel.persistency.RemoteMap; +import org.cristalise.kernel.utils.Logger; + + +/** + * @author Andrew Branson + * + * $Revision: 1.20 $ + * $Date: 2004/07/21 09:55:11 $ + * + * Copyright (C) 2003 CERN - European Organization for Nuclear Research + * All rights reserved. + */ + +public class History extends RemoteMap { + + int lastID = -1; + + public History(ItemPath itemPath, Object locker) { + super(itemPath, ClusterStorage.HISTORY, locker); + } + public Event addEvent(AgentPath agentPath, String agentRole, + String stepName, + String stepPath, + String stepType, + String stateMachineName, + Integer stateMachineVersion, + Transition transition) { + return addEvent(agentPath, agentRole, stepName, stepPath, stepType, null, null, stateMachineName, stateMachineVersion, transition, null); + } + + public Event addEvent(AgentPath agentPath, String agentRole, + String stepName, + String stepPath, + String stepType, + String schemaName, + Integer schemaVersion, + String stateMachineName, + Integer stateMachineVersion, + Transition transition, + String viewName) { + Logger.msg(7, "History.addEvent() - creating new event for "+transition.getName()+" on "+stepName+" in "+mItemPath); + Event newEvent = new Event(); + newEvent.setItemPath(mItemPath); + newEvent.setAgentPath(agentPath); + newEvent.setAgentRole(agentRole); + newEvent.setStepName(stepName); + newEvent.setStepPath(stepPath); + newEvent.setStepType(stepType); + newEvent.setSchemaName(schemaName); + newEvent.setSchemaVersion(schemaVersion); + newEvent.setViewName(viewName); + newEvent.setOriginState(transition.getOriginStateId()); + newEvent.setTargetState(transition.getTargetStateId()); + newEvent.setTransition(transition.getId()); + newEvent.setStateMachineName(stateMachineName); + newEvent.setStateMachineVersion(stateMachineVersion); + newEvent.setTimeStamp(Event.getGMT()); + return storeNewEvent(newEvent); + } + + public Event addEvent(AgentPath agentPath, String agentRole, + String stepName, + String stepPath, + String stepType, + String stateMachineName, + Integer stateMachineVersion, + Transition transition, + String timeString) throws InvalidDataException { + return addEvent(agentPath, agentRole, stepName, stepPath, stepType, null, null, stateMachineName, stateMachineVersion, transition, null, timeString); + } + + public Event addEvent(AgentPath agentPath, String agentRole, + String stepName, + String stepPath, + String stepType, + String schemaName, + Integer schemaVersion, + String stateMachineName, + Integer stateMachineVersion, + Transition transition, + String viewName, + String timeString) throws InvalidDataException { + Logger.msg(7, "History.addEvent() - creating new event for "+transition.getName()+" on "+stepName+" in "+mItemPath); + Event newEvent = new Event(); + newEvent.setItemPath(mItemPath); + newEvent.setAgentPath(agentPath); + newEvent.setAgentRole(agentRole); + newEvent.setStepName(stepName); + newEvent.setStepPath(stepPath); + newEvent.setStepType(stepType); + newEvent.setSchemaName(schemaName); + newEvent.setSchemaVersion(schemaVersion); + newEvent.setViewName(viewName); + newEvent.setOriginState(transition.getOriginStateId()); + newEvent.setTargetState(transition.getTargetStateId()); + newEvent.setTransition(transition.getId()); + newEvent.setStateMachineName(stateMachineName); + newEvent.setStateMachineVersion(stateMachineVersion); + newEvent.setTimeString(timeString); + return storeNewEvent(newEvent); + } + + private Event storeNewEvent(Event newEvent) { + synchronized (this) { + int newEventID = getLastId()+1; + newEvent.setID(newEventID); + put(newEvent.getName(), newEvent); + lastID = newEventID; + return newEvent; + } + } + + public Event getEvent(int id) { + return get(String.valueOf(id)); + } + + @Override + public Event remove(Object key) { + // forbidden + return null; + } + +} -- cgit v1.2.3