This project has retired. For details please refer to its Attic page.
BusinessLifeCyleManagerlTest xref
View Javadoc
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   *  Tests the BusinessLifecycleManagerImpl class
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              //save the Organization
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              //save
99              BulkResponse br = blm.saveClassificationSchemes(cSchemes);
100             assertEquals(BulkResponse.STATUS_SUCCESS, br.getStatus());
101             //remove
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 //          save the Organization
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             //save service
132             BulkResponse br2 = blm.saveServices(services);
133             assertEquals(BulkResponse.STATUS_SUCCESS, br2.getStatus());
134             //remove service
135             BulkResponse br3 = blm.deleteServices((Collection<Key>)br2.getCollection());
136             assertEquals(BulkResponse.STATUS_SUCCESS, br3.getStatus());
137             //remove organization
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 //          save the Organization
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             //save service
168             BulkResponse br2 = blm.saveServices(services);
169             assertEquals(BulkResponse.STATUS_SUCCESS, br2.getStatus());
170             
171             service.setKey((Key)br2.getCollection().iterator().next());
172             
173             //save serviceBinding
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             //remove serviceBindings
182             BulkResponse br6 = blm.deleteServiceBindings((Collection<Key>)br5.getCollection());
183             assertEquals(BulkResponse.STATUS_SUCCESS, br6.getStatus());
184             
185             //remove service
186             BulkResponse br3 = blm.deleteServices((Collection<Key>)br2.getCollection());
187             assertEquals(BulkResponse.STATUS_SUCCESS, br3.getStatus());
188             //remove organization
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             //setting the keys on the organizations
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             //creating the RelatedTo Association between these two organizations
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             //save associations
251             BulkResponse br2 = blm.saveAssociations(associations, true);
252             assertEquals(BulkResponse.STATUS_SUCCESS, br2.getStatus());
253             
254             //delete association
255             BulkResponse br3 = blm.deleteAssociations(br2.getCollection());
256             assertEquals(BulkResponse.STATUS_SUCCESS, br3.getStatus());
257             
258             //delete organizations
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 }