This project has retired. For details please refer to its
Attic page.
BusinessLifeCyleManagerlTest xref
1 package org.apache.ws.scout.registry;
2
3 import static org.junit.Assert.assertEquals;
4 import static org.junit.Assert.fail;
5
6 import java.util.ArrayList;
7 import java.util.Collection;
8 import java.util.Iterator;
9
10 import javax.xml.registry.BulkResponse;
11 import javax.xml.registry.JAXRException;
12 import javax.xml.registry.JAXRResponse;
13 import javax.xml.registry.RegistryService;
14 import javax.xml.registry.infomodel.Association;
15 import javax.xml.registry.infomodel.ClassificationScheme;
16 import javax.xml.registry.infomodel.Concept;
17 import javax.xml.registry.infomodel.InternationalString;
18 import javax.xml.registry.infomodel.Key;
19 import javax.xml.registry.infomodel.Organization;
20 import javax.xml.registry.infomodel.Service;
21 import javax.xml.registry.infomodel.ServiceBinding;
22
23 import junit.framework.JUnit4TestAdapter;
24
25 import org.apache.ws.scout.BaseTestCase;
26 import org.apache.ws.scout.Creator;
27 import org.junit.After;
28 import org.junit.Before;
29 import org.junit.Ignore;
30 import org.junit.Test;
31
32
33
34
35
36 public class BusinessLifeCyleManagerlTest extends BaseTestCase
37 {
38 @Before
39 public void setUp()
40 {
41 super.setUp();
42 }
43
44 @After
45 public void tearDown()
46 {
47 super.tearDown();
48 }
49
50 @SuppressWarnings("unchecked")
51 @Test
52 public void saveDeleteOrganizations()
53 {
54 login();
55 Collection<Key> orgKeys = new ArrayList<Key>();
56 try {
57 RegistryService rs = connection.getRegistryService();
58 blm = rs.getBusinessLifeCycleManager();
59 Creator.html#Creator">Creator creator = new Creator(blm);
60 Collection<Organization> orgs = new ArrayList<Organization>();
61 Organization organization = creator.createOrganization(this.getClass().getName());
62 orgs.add(organization);
63
64
65 BulkResponse br = blm.saveOrganizations(orgs);
66 assertEquals(JAXRResponse.STATUS_SUCCESS, br.getStatus());
67 orgKeys = (Collection<Key>) br.getCollection();
68 } catch (Exception e) {
69 e.printStackTrace();
70 fail(e.getMessage());
71 }
72
73 try {
74 RegistryService rs = connection.getRegistryService();
75 blm = rs.getBusinessLifeCycleManager();
76 BulkResponse br = blm.deleteOrganizations(orgKeys);
77 assertEquals(JAXRResponse.STATUS_SUCCESS, br.getStatus());
78 } catch (Exception e) {
79 e.printStackTrace();
80 fail(e.getMessage());
81 }
82 }
83
84 @SuppressWarnings("unchecked")
85 @Test
86 public void saveDeleteClassificationSchemes()
87 {
88 login();
89
90 try {
91 RegistryService rs = connection.getRegistryService();
92 blm = rs.getBusinessLifeCycleManager();
93
94 ClassificationScheme cScheme = blm.createClassificationScheme("testScheme -- APACHE SCOUT TEST", "Sample Classification Scheme");
95
96 ArrayList<ClassificationScheme> cSchemes = new ArrayList<ClassificationScheme>();
97 cSchemes.add(cScheme);
98
99 BulkResponse br = blm.saveClassificationSchemes(cSchemes);
100 assertEquals(BulkResponse.STATUS_SUCCESS, br.getStatus());
101
102 BulkResponse br2 = blm.deleteClassificationSchemes((Collection<Key>)br.getCollection());
103 assertEquals(BulkResponse.STATUS_SUCCESS, br2.getStatus());
104 } catch (JAXRException je) {
105 fail(je.getMessage());
106 }
107 }
108
109 @SuppressWarnings("unchecked")
110 @Test
111 public void saveDeleteServices()
112 {
113 login();
114
115 try {
116 RegistryService rs = connection.getRegistryService();
117 blm = rs.getBusinessLifeCycleManager();
118 Creator.html#Creator">Creator creator = new Creator(blm);
119 Collection<Organization> orgs = new ArrayList<Organization>();
120 Organization organization = creator.createOrganization(this.getClass().getName());
121 orgs.add(organization);
122
123 BulkResponse br = blm.saveOrganizations(orgs);
124 assertEquals(JAXRResponse.STATUS_SUCCESS, br.getStatus());
125 organization.setKey((Key)br.getCollection().iterator().next());
126
127 Service service = creator.createService(this.getClass().getName());
128 ArrayList<Service> services = new ArrayList<Service>();
129 organization.addService(service);
130 services.add(service);
131
132 BulkResponse br2 = blm.saveServices(services);
133 assertEquals(BulkResponse.STATUS_SUCCESS, br2.getStatus());
134
135 BulkResponse br3 = blm.deleteServices((Collection<Key>)br2.getCollection());
136 assertEquals(BulkResponse.STATUS_SUCCESS, br3.getStatus());
137
138 BulkResponse br4 = blm.deleteOrganizations((Collection<Key>)br.getCollection());
139 assertEquals(JAXRResponse.STATUS_SUCCESS, br4.getStatus());
140 } catch (JAXRException je) {
141 fail(je.getMessage());
142 }
143 }
144
145 @SuppressWarnings("unchecked")
146 @Test
147 public void saveDeleteServiceBindings()
148 {
149 login();
150
151 try {
152 RegistryService rs = connection.getRegistryService();
153 blm = rs.getBusinessLifeCycleManager();
154 Creator.html#Creator">Creator creator = new Creator(blm);
155 Collection<Organization> orgs = new ArrayList<Organization>();
156 Organization organization = creator.createOrganization(this.getClass().getName());
157 orgs.add(organization);
158
159 BulkResponse br = blm.saveOrganizations(orgs);
160 assertEquals(JAXRResponse.STATUS_SUCCESS, br.getStatus());
161 organization.setKey((Key)br.getCollection().iterator().next());
162
163 Service service = creator.createService(this.getClass().getName());
164 ArrayList<Service> services = new ArrayList<Service>();
165 organization.addService(service);
166 services.add(service);
167
168 BulkResponse br2 = blm.saveServices(services);
169 assertEquals(BulkResponse.STATUS_SUCCESS, br2.getStatus());
170
171 service.setKey((Key)br2.getCollection().iterator().next());
172
173
174 ServiceBinding serviceBinding = creator.createServiceBinding();
175 service.addServiceBinding(serviceBinding);
176 ArrayList<ServiceBinding> serviceBindings = new ArrayList<ServiceBinding>();
177 serviceBindings.add(serviceBinding);
178 BulkResponse br5 = blm.saveServiceBindings(serviceBindings);
179 assertEquals(BulkResponse.STATUS_SUCCESS, br5.getStatus());
180
181
182 BulkResponse br6 = blm.deleteServiceBindings((Collection<Key>)br5.getCollection());
183 assertEquals(BulkResponse.STATUS_SUCCESS, br6.getStatus());
184
185
186 BulkResponse br3 = blm.deleteServices((Collection<Key>)br2.getCollection());
187 assertEquals(BulkResponse.STATUS_SUCCESS, br3.getStatus());
188
189 BulkResponse br4 = blm.deleteOrganizations((Collection<Key>)br.getCollection());
190 assertEquals(JAXRResponse.STATUS_SUCCESS, br4.getStatus());
191 } catch (JAXRException je) {
192 fail(je.getMessage());
193 }
194 }
195
196 @SuppressWarnings("unchecked")
197 @Test
198 public void saveDeleteConcepts()
199 {
200 login();
201 try {
202 RegistryService rs = connection.getRegistryService();
203 blm = rs.getBusinessLifeCycleManager();
204 Collection<Concept> concepts = new ArrayList<Concept>();
205 Concept concept = blm.createConcept(null, "TestConcept", "");
206 InternationalString is = blm.createInternationalString("This is the concept for Apache Scout Test");
207 concept.setDescription(is);
208 concepts.add(concept);
209
210 BulkResponse br = blm.saveConcepts(concepts);
211 assertEquals(BulkResponse.STATUS_SUCCESS, br.getStatus());
212
213 BulkResponse br2 = blm.deleteConcepts((Collection<Key>)br.getCollection());
214 assertEquals(BulkResponse.STATUS_SUCCESS, br2.getStatus());
215 } catch (JAXRException je) {
216 fail(je.getMessage());
217 }
218 }
219
220 @SuppressWarnings("unchecked")
221 @Test
222 public void saveDeleteAssociations()
223 {
224 login();
225 try {
226 RegistryService rs = connection.getRegistryService();
227 blm = rs.getBusinessLifeCycleManager();
228 bqm = rs.getBusinessQueryManager();
229 Creator.html#Creator">Creator creator = new Creator(blm);
230
231 System.out.println("\nCreating temporary organizations...\n");
232 Organization sOrg = creator.createOrganization("sourceOrg");
233 Organization tOrg = creator.createOrganization("targetOrg");
234 Collection<Organization> organizations = new ArrayList<Organization>();
235 organizations.add(sOrg);
236 organizations.add(tOrg);
237 BulkResponse br = blm.saveOrganizations(organizations);
238 assertEquals(BulkResponse.STATUS_SUCCESS, br.getStatus());
239
240 Collection<Key> keys = (Collection<Key>) br.getCollection();
241 Iterator<Key> iterator = keys.iterator();
242 sOrg.setKey(iterator.next());
243 tOrg.setKey(iterator.next());
244
245 Concept type = bqm.findConceptByPath("/AssociationType/RelatedTo");
246 Association association = blm.createAssociation(tOrg, type);
247 sOrg.addAssociation(association);
248 ArrayList<Association> associations = new ArrayList<Association>();
249 associations.add(association);
250
251 BulkResponse br2 = blm.saveAssociations(associations, true);
252 assertEquals(BulkResponse.STATUS_SUCCESS, br2.getStatus());
253
254
255 BulkResponse br3 = blm.deleteAssociations(br2.getCollection());
256 assertEquals(BulkResponse.STATUS_SUCCESS, br3.getStatus());
257
258
259 BulkResponse br4 = blm.deleteOrganizations((Collection<Key>)br.getCollection());
260 assertEquals(BulkResponse.STATUS_SUCCESS, br4.getStatus());
261
262 } catch (JAXRException je) {
263 fail(je.getMessage());
264 je.printStackTrace();
265 }
266 }
267
268 public static junit.framework.Test suite() {
269 return new JUnit4TestAdapter(BusinessLifeCyleManagerlTest.class);
270 }
271
272 }