1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
|
package com.c2kernel.lifecycle.instance.predefined.entitycreation;
import java.util.ArrayList;
import com.c2kernel.collection.MembershipException;
import com.c2kernel.common.CannotManageException;
import com.c2kernel.common.ObjectAlreadyExistsException;
import com.c2kernel.common.ObjectCannotBeUpdated;
import com.c2kernel.common.ObjectNotFoundException;
import com.c2kernel.entity.TraceableEntity;
import com.c2kernel.lifecycle.CompositeActivityDef;
import com.c2kernel.lookup.DomainPath;
import com.c2kernel.lookup.EntityPath;
import com.c2kernel.persistency.ClusterStorageException;
import com.c2kernel.process.Gateway;
import com.c2kernel.property.PropertyArrayList;
import com.c2kernel.utils.CastorXMLUtility;
import com.c2kernel.utils.LocalObjectLoader;
import com.c2kernel.utils.Logger;
/**
* Complete Structure for new item
*
* @version $Revision: 1.8 $ $Date: 2006/03/03 13:52:21 $
*/
public class NewItem {
public String name;
/**
* The initial Domain Path to be created for this Item.
*/
public String initialPath;
/**
* The name of the Composite Activity Definition to be
* instantiated for the workflow of this Item
*/
public String workflow;
/**
* New Properties for the item
*/
public ArrayList<Property> propertyList;
/**
* Field _aggregationList
*/
public ArrayList<Aggregation> aggregationList;
/**
* Field _dependencyList
*/
public ArrayList<Dependency> dependencyList;
public NewItem() {
super();
propertyList = new ArrayList<Property>();
aggregationList = new ArrayList<Aggregation>();
dependencyList = new ArrayList<Dependency>();
}
public NewItem(String name, String initialPath, String wf) {
this();
this.name = name;
this.initialPath = initialPath;
this.workflow = wf;
}
public void setProperty(String name, String value) {
for (Property prop : propertyList) {
if (prop.name.equals(name)) {
prop.value = value;
return;
}
}
propertyList.add(new Property(name, value));
}
protected void create(int agentId) throws ObjectCannotBeUpdated, ObjectNotFoundException, CannotManageException, ObjectAlreadyExistsException {
DomainPath domPath = new DomainPath(new DomainPath(initialPath), name);
if (domPath.exists())
throw new ObjectAlreadyExistsException(domPath+" already exists!", "");
// create item
EntityPath entPath = Gateway.getLDAPLookup().getNextKeyManager().generateNextEntityKey();
TraceableEntity newItem = (TraceableEntity)Gateway.getCorbaServer().createEntity(entPath);
Gateway.getLDAPLookup().add(entPath);
// assemble properties
PropertyArrayList propList = new PropertyArrayList();
propList.list.add(new com.c2kernel.property.Property("Name", name));
for (Property element : propertyList) {
propList.list.add(new com.c2kernel.property.Property(element.name, element.value));
}
// init the new item
try {
// find workflow def
CompositeActivityDef compact = (CompositeActivityDef)LocalObjectLoader.getActDef(workflow, "last");
newItem.initialise(
agentId,
CastorXMLUtility.marshall(propList),
CastorXMLUtility.marshall(compact.instantiate()));
} catch (Exception ex) {
Logger.error("Error initialising new item");
Logger.error(ex);
throw new CannotManageException("Problem initialising new item. See server log.", "");
}
// create collections
for (Dependency element: dependencyList) {
try {
Gateway.getStorage().put(entPath.getSysKey(), element.create(), null);
} catch (ClusterStorageException ex) {
Logger.error(ex);
throw new CannotManageException("Could not create Dependency "+element.name, "");
} catch (MembershipException ex) {
Logger.error(ex);
throw new CannotManageException("A specified member is not of the correct type in "+element.name, "");
}
}
for (Aggregation element : aggregationList) {
try {
Gateway.getStorage().put(entPath.getSysKey(), element.create(), null);
} catch (ClusterStorageException ex) {
Logger.error(ex);
throw new CannotManageException("Could not create Aggregation "+element.name, "");
}
}
// register domain path
domPath.setEntity(entPath);
Gateway.getLDAPLookup().add(domPath);
}
}
|
