From: <ms...@us...> - 2007-01-22 08:23:31
|
Revision: 160 http://svn.sourceforge.net/unicore/?rev=160&view=rev Author: msmemon Date: 2007-01-22 00:23:28 -0800 (Mon, 22 Jan 2007) Log Message: ----------- - resource property test cases Added Paths: ----------- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivityReferenceRP.java omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestIsAcceptingNewActivitiesRP.java omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestNamingProfileRP.java Added: omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivityReferenceRP.java =================================================================== --- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivityReferenceRP.java (rev 0) +++ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivityReferenceRP.java 2007-01-22 08:23:28 UTC (rev 160) @@ -0,0 +1,162 @@ +package de.fzj.unicore.bes.test.factory; + +import java.io.File; +import java.io.IOException; +import java.util.logging.Logger; + +import org.apache.xmlbeans.XmlCursor; +import org.apache.xmlbeans.XmlException; +import org.ggf.schemas.bes.x2006.x08.besFactory.ActivityDocumentDocument1; +import org.ggf.schemas.bes.x2006.x08.besFactory.CreateActivityDocument; +import org.ggf.schemas.bes.x2006.x08.besFactory.CreateActivityResponseDocument; +import org.ggf.schemas.jsdl.x2005.x11.jsdl.JobDefinitionDocument; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyDocument; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyResponseDocument; +import de.fzj.unicore.bes.BESActivity; +import de.fzj.unicore.bes.BESFactory; +import de.fzj.unicore.bes.impl.activity.BESActivityHomeImpl; +import de.fzj.unicore.bes.impl.activity.BESActivityImpl; +import de.fzj.unicore.bes.impl.factory.BESFactoryHomeImpl; +import de.fzj.unicore.wsrflite.Home; +import de.fzj.unicore.wsrflite.Kernel; +import de.fzj.unicore.wsrflite.utils.Utilities; +import de.fzj.unicore.wsrflite.xfire.JettyTestCase; +import de.fzj.unicore.wsrflite.xfire.XFireKernel; + +public class TestActivityReferenceRP extends JettyTestCase { + + private static Logger logger = Logger + .getLogger(TestActivityReferenceRP.class.getName()); + + @Override + protected void addServices() throws Exception { + XFireKernel.exposeAsService("BESFactory", BESFactory.class, + BESFactoryHomeImpl.class, true); + + XFireKernel.exposeAsService("BESActivity", BESActivity.class, + BESActivityHomeImpl.class, true); + + } + + private ActivityDocumentDocument1 prepareActivity() { + ActivityDocumentDocument1 aDoc = ActivityDocumentDocument1.Factory + .newInstance(); + + try { + JobDefinitionDocument jDoc = JobDefinitionDocument.Factory + .parse(new File( + "/home/m.memon/workspace/ogsa-bes/src/test/resources/jsdlinstance.xml")); + aDoc.addNewActivityDocument().setJobDefinition( + jDoc.getJobDefinition()); + + logger.info("Comeon In Test test: " + aDoc.toString()); + } catch (XmlException e) { + logger.severe(e.getMessage()); + fail(); + } catch (IOException e) { + logger.severe(e.getMessage()); + fail(); + } + + return aDoc; + } + + public void testGetActivityReferences() { + + try { + ActivityDocumentDocument1 acDoc = ActivityDocumentDocument1.Factory + .newInstance(); + Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); + String bfId = bfHome.createWSRFServiceInstance(null); + BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfId); + CreateActivityDocument caDoc = CreateActivityDocument.Factory + .newInstance(); + caDoc.addNewCreateActivity().setActivityDocument( + prepareActivity().getActivityDocument()); + CreateActivityResponseDocument cresDoc = bfObj + .createActivity(caDoc); + CreateActivityResponseDocument cresDoc2 = bfObj + .createActivity(caDoc); + CreateActivityResponseDocument cresDoc3 = bfObj + .createActivity(caDoc); + CreateActivityResponseDocument cresDoc4 = bfObj + .createActivity(caDoc); + + Home activityHome = Kernel.getKernel() + .getServiceHome("BESActivity"); + String str = Utilities.extractResourceID(cresDoc + .getCreateActivityResponse().getActivityIdentifier()); + System.out.println("BA ResourceID 1: " + str); + BESActivityImpl activity = (BESActivityImpl) activityHome + .getWSRFServiceInstance(str); + + String str2 = Utilities.extractResourceID(cresDoc2 + .getCreateActivityResponse().getActivityIdentifier()); + System.out.println("BA ResourceID 2: " + str2); + BESActivityImpl activity2 = (BESActivityImpl) activityHome + .getWSRFServiceInstance(str2); + + String str3 = Utilities.extractResourceID(cresDoc3 + .getCreateActivityResponse().getActivityIdentifier()); + System.out.println("BA ResourceID 3: " + str3); + BESActivityImpl activity3 = (BESActivityImpl) activityHome + .getWSRFServiceInstance(str3); + + String str4 = Utilities.extractResourceID(cresDoc4 + .getCreateActivityResponse().getActivityIdentifier()); + System.out.println("BA ResourceID 4: " + str4); + BESActivityImpl activity4 = (BESActivityImpl) activityHome + .getWSRFServiceInstance(str4); + + GetResourcePropertyDocument grpDoc = GetResourcePropertyDocument.Factory + .newInstance(); + grpDoc.setGetResourceProperty(BESFactory.RPActivityReference); + + GetResourcePropertyResponseDocument res = bfObj + .GetResourceProperty(grpDoc); + + logger.info("activity Reference RP: " + res.toString()); + assertNotNull(res.toString().contains(activity.getUniqueID())); + assertNotNull(res.toString().contains(activity2.getUniqueID())); + assertNotNull(res.toString().contains(activity3.getUniqueID())); + assertNotNull(res.toString().contains(activity4.getUniqueID())); + + } catch (Exception e) { + fail(); + logger.severe("Test Fails: " + e.getMessage()); + } + + } + + public void testTotalNumberOfActivities() throws Exception { + ActivityDocumentDocument1 acDoc = ActivityDocumentDocument1.Factory + .newInstance(); + Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); + String bfId = bfHome.createWSRFServiceInstance(null); + BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfId); + CreateActivityDocument caDoc = CreateActivityDocument.Factory + .newInstance(); + caDoc.addNewCreateActivity().setActivityDocument( + prepareActivity().getActivityDocument()); + CreateActivityResponseDocument cresDoc = bfObj.createActivity(caDoc); + cresDoc = bfObj.createActivity(caDoc); + cresDoc = bfObj.createActivity(caDoc); + cresDoc = bfObj.createActivity(caDoc); + + GetResourcePropertyDocument grpDoc = GetResourcePropertyDocument.Factory + .newInstance(); + grpDoc.setGetResourceProperty(BESFactory.RPTotalNumberOfActivities); + + GetResourcePropertyResponseDocument res = bfObj + .GetResourceProperty(grpDoc); + logger.info("number of activities rp:" + res.toString()); + XmlCursor cursor = res.newCursor(); + cursor.toFirstChild(); + cursor.toFirstChild(); + + assertEquals(4, Integer.parseInt(cursor.getTextValue())); + } + + + +} Added: omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestIsAcceptingNewActivitiesRP.java =================================================================== --- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestIsAcceptingNewActivitiesRP.java (rev 0) +++ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestIsAcceptingNewActivitiesRP.java 2007-01-22 08:23:28 UTC (rev 160) @@ -0,0 +1,162 @@ +package de.fzj.unicore.bes.test.factory; + +import java.io.File; +import java.io.IOException; +import java.util.logging.Logger; + +import org.apache.xmlbeans.XmlCursor; +import org.apache.xmlbeans.XmlException; +import org.apache.xmlbeans.XmlObject; +import org.codehaus.xfire.service.Service; +import org.ggf.schemas.bes.x2006.x08.besFactory.ActivityDocumentDocument1; +import org.ggf.schemas.bes.x2006.x08.besFactory.CreateActivityDocument; +import org.ggf.schemas.bes.x2006.x08.besFactory.CreateActivityResponseDocument; +import org.ggf.schemas.jsdl.x2005.x11.jsdl.JobDefinitionDocument; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyDocument; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyResponseDocument; +import org.omiiEurope.unicore.ogsaBes.GetBESFactoryInstanceRequestDocument; +import org.omiiEurope.unicore.ogsaBes.GetBESFactoryInstanceResponseDocument; +import org.w3.x2005.x08.addressing.EndpointReferenceType; + +import de.fzj.unicore.bes.AbstractBESFactory; +import de.fzj.unicore.bes.BES; +import de.fzj.unicore.bes.BESActivity; +import de.fzj.unicore.bes.BESFactory; +import de.fzj.unicore.bes.fault.factory.NotAcceptingNewActivitiesFault; +import de.fzj.unicore.bes.impl.activity.BESActivityHomeImpl; +import de.fzj.unicore.bes.impl.factory.AbstractBESFactoryImpl; +import de.fzj.unicore.bes.impl.factory.BESFactoryHomeImpl; +import de.fzj.unicore.wsrflite.Home; +import de.fzj.unicore.wsrflite.Kernel; +import de.fzj.unicore.wsrflite.ResourceProperty; +import de.fzj.unicore.wsrflite.utils.Utilities; +import de.fzj.unicore.wsrflite.xfire.JettyTestCase; +import de.fzj.unicore.wsrflite.xfire.XFireClientFactory; +import de.fzj.unicore.wsrflite.xfire.XFireKernel; + +public class TestIsAcceptingNewActivitiesRP extends JettyTestCase { + + private static Logger logger = Logger + .getLogger(TestIsAcceptingNewActivitiesRP.class.getName()); + + private static Service abstractBESFactory = null; + + @Override + protected void addServices() throws Exception { + XFireKernel.exposeAsService("BESFactory", BESFactory.class, + BESFactoryHomeImpl.class, true); + abstractBESFactory = XFireKernel.exposeAsService("AbstractBESFactory", + AbstractBESFactory.class, AbstractBESFactoryImpl.class, false); + } + + public void testGetActivityFlag() { + + EndpointReferenceType eprt; + try { + eprt = createBESFactoryInstance(); + String bfid = Utilities.extractResourceID(eprt); + Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); + BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); + + GetResourcePropertyDocument grpDoc = GetResourcePropertyDocument.Factory + .newInstance(); + grpDoc + .setGetResourceProperty(BESFactory.RPIsAcceptingNewActivities); + + GetResourcePropertyResponseDocument res = bfObj + .GetResourceProperty(grpDoc); + + Boolean b = new Boolean(BES + .getProperty(BES.IS_ACCEPTING_NEW_ACTIVITIES)); + + XmlCursor cursor = res.newCursor(); + cursor.toFirstChild(); + cursor.toFirstChild(); + + assertEquals(b.toString(), cursor.getTextValue()); + + logger.info("IsAccepting new activities: " + res.toString()); + } catch (Exception e) { + logger.info(e.getMessage()); + fail(); + } + + } + + private EndpointReferenceType createBESFactoryInstance() throws Exception { + GetBESFactoryInstanceRequestDocument gReq = GetBESFactoryInstanceRequestDocument.Factory + .newInstance(); + gReq.addNewGetBESFactoryInstanceRequest(); + + XFireClientFactory proxyMaker = new XFireClientFactory(); + System.out.println("getting proxy object"); + AbstractBESFactory abfObj = (AbstractBESFactory) proxyMaker + .createPlainWSProxy(AbstractBESFactory.class, + "http://localhost:7777/services/AbstractBESFactory", + null); + + System.out.println(abfObj.toString()); + GetBESFactoryInstanceResponseDocument gRes = abfObj + .getBESFactoryInstance(gReq); + System.out.println("helol"); + System.out.println(gRes.toString()); + + + return gRes.getGetBESFactoryInstanceResponse().getBfreference(); + } + + + // checks if flag is false +// private void testCreateActivity() { +// EndpointReferenceType eprt; +// BESFactory bfObj = null; +// try{ +// eprt = createBESFactoryInstance(); +// String bfid = Utilities.extractResourceID(eprt); +// Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); +// bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); +// } +// catch(Exception e){ +// logger.severe(e.getMessage()); +// } +// CreateActivityDocument caDoc = CreateActivityDocument.Factory +// .newInstance(); +// caDoc.addNewCreateActivity().setActivityDocument( +// prepareActivity().getActivityDocument()); +// try { +// CreateActivityResponseDocument cresDoc = bfObj.createActivity(caDoc); +// } catch (NotAcceptingNewActivitiesFault e) { +// logger.severe(e.getMessage()); +// assertTrue(true); +// } +// +// +// +// +// +// } + + private ActivityDocumentDocument1 prepareActivity() { + ActivityDocumentDocument1 aDoc = ActivityDocumentDocument1.Factory + .newInstance(); + + try { + JobDefinitionDocument jDoc = JobDefinitionDocument.Factory + .parse(new File( + "/home/m.memon/workspace/ogsa-bes/src/test/resources/jsdlinstance.xml")); + aDoc.addNewActivityDocument().setJobDefinition( + jDoc.getJobDefinition()); + + logger.info("Comeon In Test test: " + aDoc.toString()); + } catch (XmlException e) { + logger.severe(e.getMessage()); + fail(); + } catch (IOException e) { + logger.severe(e.getMessage()); + fail(); + } + + return aDoc; + } + +} Added: omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestNamingProfileRP.java =================================================================== --- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestNamingProfileRP.java (rev 0) +++ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestNamingProfileRP.java 2007-01-22 08:23:28 UTC (rev 160) @@ -0,0 +1,118 @@ +package de.fzj.unicore.bes.test.factory; + +import java.util.logging.Logger; + +import org.apache.xmlbeans.XmlCursor; +import org.codehaus.xfire.service.Service; +import org.ggf.schemas.bes.x2006.x08.besFactory.ActivityDocumentDocument1; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyDocument; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyDocumentDocument1; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyDocumentResponseDocument; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyResponseDocument; +import org.omiiEurope.unicore.ogsaBes.GetBESFactoryInstanceRequestDocument; +import org.omiiEurope.unicore.ogsaBes.GetBESFactoryInstanceResponseDocument; +import org.w3.x2005.x08.addressing.EndpointReferenceType; + +import de.fzj.unicore.bes.AbstractBESFactory; +import de.fzj.unicore.bes.BES; +import de.fzj.unicore.bes.BESFactory; +import de.fzj.unicore.bes.impl.factory.AbstractBESFactoryImpl; +import de.fzj.unicore.bes.impl.factory.BESFactoryHomeImpl; +import de.fzj.unicore.wsrflite.Home; +import de.fzj.unicore.wsrflite.Kernel; +import de.fzj.unicore.wsrflite.utils.Utilities; +import de.fzj.unicore.wsrflite.xfire.JettyTestCase; +import de.fzj.unicore.wsrflite.xfire.XFireClientFactory; +import de.fzj.unicore.wsrflite.xfire.XFireKernel; + +public class TestNamingProfileRP extends JettyTestCase { + + private Service abstractBESFactory = null; + + private Logger logger = Logger.getLogger(TestNamingProfileRP.class + .getName()); + + @Override + protected void addServices() throws Exception { + XFireKernel.exposeAsService("BESFactory", BESFactory.class, + BESFactoryHomeImpl.class, true); + abstractBESFactory = XFireKernel.exposeAsService("AbstractBESFactory", + AbstractBESFactory.class, AbstractBESFactoryImpl.class, false); + + } + + protected EndpointReferenceType createBESFactoryInstance() throws Exception { + GetBESFactoryInstanceRequestDocument gReq = GetBESFactoryInstanceRequestDocument.Factory + .newInstance(); + gReq.addNewGetBESFactoryInstanceRequest(); + + XFireClientFactory proxyMaker = new XFireClientFactory(); + System.out.println("getting proxy object"); + AbstractBESFactory abfObj = (AbstractBESFactory) proxyMaker + .createPlainWSProxy(AbstractBESFactory.class, + "http://localhost:7777/services/AbstractBESFactory", + null); + + System.out.println(abfObj.toString()); + GetBESFactoryInstanceResponseDocument gRes = abfObj + .getBESFactoryInstance(gReq); + System.out.println("helol"); + System.out.println(gRes.toString()); + + return gRes.getGetBESFactoryInstanceResponse().getBfreference(); + } + +// public void testNamingProfile() { +// EndpointReferenceType eprt; +// try { +// eprt = createBESFactoryInstance(); +// String bfid = Utilities.extractResourceID(eprt); +// Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); +// BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); +// +// GetResourcePropertyDocument grpDoc = GetResourcePropertyDocument.Factory +// .newInstance(); +// grpDoc.setGetResourceProperty(BESFactory.RPNamingProfile); +// +// GetResourcePropertyResponseDocument res = bfObj +// .GetResourceProperty(grpDoc); +// +// System.out.println(res.toString()); +// +// String qname = BES.getProperty(BES.NAMING_PROFILE); +// XmlCursor cursor = res.newCursor(); +// cursor.toFirstChild(); +// cursor.toFirstChild(); +// +// assertEquals(qname, cursor.getTextValue()); +// +// logger.info("IsAccepting new activities: " + res.toString()); +// } catch (Exception e) { +// logger.info(e.getMessage()); +// fail(); +// } +// } + + public void testGetResourcePropertyDocument() { + EndpointReferenceType eprt; + try { + eprt = createBESFactoryInstance(); + String bfid = Utilities.extractResourceID(eprt); + Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); + BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); + Thread.sleep(2000); + GetResourcePropertyDocumentDocument1 grpDoc = GetResourcePropertyDocumentDocument1.Factory + .newInstance(); + grpDoc.addNewGetResourcePropertyDocument(); + GetResourcePropertyDocumentResponseDocument gRes = bfObj + .GetResourcePropertyDocument(grpDoc); + logger.info("hello, "+gRes.toString()); + } catch (Exception e) { + logger.info(e.getMessage()); + fail(); + } + } + + + +} This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |
From: <ms...@us...> - 2007-01-22 08:35:48
|
Revision: 167 http://svn.sourceforge.net/unicore/?rev=167&view=rev Author: msmemon Date: 2007-01-22 00:35:47 -0800 (Mon, 22 Jan 2007) Log Message: ----------- Modified Paths: -------------- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestAbstractBESFactory.java omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestBESFactory.java Modified: omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestAbstractBESFactory.java =================================================================== --- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestAbstractBESFactory.java 2007-01-22 08:35:12 UTC (rev 166) +++ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestAbstractBESFactory.java 2007-01-22 08:35:47 UTC (rev 167) @@ -54,10 +54,8 @@ return gRes.getGetBESFactoryInstanceResponse().getBfreference(); } - public void testBESFactoryCreation() throws Exception { + - } - public void testInstanceCreation() throws Exception { assertNotNull(createBESFactoryInstance()); } Modified: omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestBESFactory.java =================================================================== --- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestBESFactory.java 2007-01-22 08:35:12 UTC (rev 166) +++ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestBESFactory.java 2007-01-22 08:35:47 UTC (rev 167) @@ -7,34 +7,48 @@ import javax.xml.namespace.QName; import org.apache.xmlbeans.XmlException; +import org.codehaus.xfire.service.Service; import org.ggf.schemas.bes.x2006.x08.besFactory.ActivityDocumentDocument1; import org.ggf.schemas.bes.x2006.x08.besFactory.ActivityDocumentType; import org.ggf.schemas.bes.x2006.x08.besFactory.CreateActivityDocument; import org.ggf.schemas.bes.x2006.x08.besFactory.CreateActivityResponseDocument; +import org.ggf.schemas.bes.x2006.x08.besFactory.GetFactoryAttributesDocumentDocument1; +import org.ggf.schemas.bes.x2006.x08.besFactory.GetFactoryAttributesDocumentResponseDocument; import org.ggf.schemas.jsdl.x2005.x11.jsdl.JobDefinitionDocument; import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyDocument; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyDocumentDocument1; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyDocumentResponseDocument; import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyResponseDocument; import org.omiiEurope.unicore.ogsaBes.FetchOutcomeRequestDocument; import org.omiiEurope.unicore.ogsaBes.FetchOutcomeResponseDocument; +import org.omiiEurope.unicore.ogsaBes.GetBESFactoryInstanceRequestDocument; +import org.omiiEurope.unicore.ogsaBes.GetBESFactoryInstanceResponseDocument; import org.w3.x2005.x08.addressing.EndpointReferenceDocument; import org.w3.x2005.x08.addressing.EndpointReferenceType; -import com.intel.util.EPRUtil; - +import de.fzj.unicore.bes.AbstractBESFactory; import de.fzj.unicore.bes.BESActivity; import de.fzj.unicore.bes.BESFactory; import de.fzj.unicore.bes.impl.activity.BESActivityHomeImpl; import de.fzj.unicore.bes.impl.activity.BESActivityImpl; +import de.fzj.unicore.bes.impl.factory.AbstractBESFactoryImpl; import de.fzj.unicore.bes.impl.factory.BESFactoryHomeImpl; +import de.fzj.unicore.bes.test.factory.TestActivityReferenceRP; import de.fzj.unicore.wsrflite.BaseFault; import de.fzj.unicore.wsrflite.Home; import de.fzj.unicore.wsrflite.Kernel; import de.fzj.unicore.wsrflite.utils.Utilities; import de.fzj.unicore.wsrflite.xfire.JettyTestCase; +import de.fzj.unicore.wsrflite.xfire.XFireClientFactory; import de.fzj.unicore.wsrflite.xfire.XFireKernel; public class TestBESFactory extends JettyTestCase { + private static Logger logger = Logger.getLogger(TestBESFactory.class + .getName()); + + private Service abstractBESFactory = null; + @Override protected void addServices() throws Exception { // TODO Auto-generated method stub @@ -44,6 +58,9 @@ XFireKernel.exposeAsService("BESActivity", BESActivity.class, BESActivityHomeImpl.class, true); + + abstractBESFactory = XFireKernel.exposeAsService("AbstractBESFactory", + AbstractBESFactory.class, AbstractBESFactoryImpl.class, false); } @@ -54,99 +71,140 @@ try { JobDefinitionDocument jDoc = JobDefinitionDocument.Factory - .parse(new File("./src/test/resources/jsdlinstance.xml")); + .parse(new File("/home/m.memon/workspace/ogsa-bes/src/test/resources/jsdlinstance.xml")); + aDoc.addNewActivityDocument().setJobDefinition( jDoc.getJobDefinition()); - + + logger.info("aDoc : " + aDoc.toString()); } catch (XmlException e) { - - e.printStackTrace(); + logger.severe(e.getMessage()); } catch (IOException e) { - e.printStackTrace(); + logger.severe(e.getMessage()); + } catch (Exception e) { + logger.severe(e.getMessage()); } - + return aDoc; } - public void testCreateActivity() throws Exception { +// public void testCreateActivity() throws Exception { +// try { +// +// ActivityDocumentDocument1 actDoc = prepareActivity(); +// CreateActivityDocument caDoc = CreateActivityDocument.Factory +// .newInstance(); +// caDoc.addNewCreateActivity().setActivityDocument( +// actDoc.getActivityDocument()); +// +// // create factory instance +// Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); +// String bfId = bfHome.createWSRFServiceInstance(null); +// +// System.out.println("BESFactory ID: " + bfId); +// +// BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfId); +// CreateActivityResponseDocument cresDoc = bfObj +// .createActivity(caDoc); +// +// Home activityHome = Kernel.getKernel() +// .getServiceHome("BESActivity"); +// String str = Utilities.extractResourceID(cresDoc +// .getCreateActivityResponse().getActivityIdentifier()); +// System.out.println("BA ResourceID: " + str); +// BESActivityImpl activity = (BESActivityImpl) activityHome +// .getWSRFServiceInstance(str); +// // ///////////////////////////////////////// +// // checking output////////////////////////// +// // //////////////////////////////////////// +// +// // ///////////////////////////////////////////////////////////////////////// +// GetResourcePropertyDocument propDoc = GetResourcePropertyDocument.Factory +// .newInstance(); +// propDoc.setGetResourceProperty(BESActivity.RPFactoryReference); +// GetResourcePropertyResponseDocument resPropDoc = activity +// .GetResourceProperty(propDoc); +// +// System.out.println("EPR of BF from BA: " +// + resPropDoc.getGetResourcePropertyResponse().toString()); +// EndpointReferenceDocument eprDoc = EndpointReferenceDocument.Factory +// .parse(resPropDoc.getGetResourcePropertyResponse() +// .toString()); +// +// // ///////////////////////////////////////////////////////////////////////// +// +// System.out.println("In test case: "); +// String epr = cresDoc.getCreateActivityResponse() +// .getActivityIdentifier().getAddress().getStringValue(); +// System.out.println("The epr of Activity: " + epr); +// +// assertEquals(bfId, Utilities.extractResourceID(eprDoc +// .getEndpointReference())); +// Thread.sleep(3000); +// getJobOutcome(activity); +// } catch (Exception e) { +// e.printStackTrace(); +// } +// +// } + + private void getJobOutcome(BESActivityImpl acImpl) { + FetchOutcomeRequestDocument req = FetchOutcomeRequestDocument.Factory + .newInstance(); + req.addNewFetchOutcomeRequest(); + try { + FetchOutcomeResponseDocument fres = acImpl.fetchOutcome(req); + System.out.println("output of job:::::: " + fres.toString()); + } catch (BaseFault e) { + fail(); + System.out.println("Severe : " + e.getMessage()); + } - ActivityDocumentDocument1 actDoc = prepareActivity(); - CreateActivityDocument caDoc = CreateActivityDocument.Factory - .newInstance(); - caDoc.addNewCreateActivity().setActivityDocument( - actDoc.getActivityDocument()); - - // create factory instance + } + + public void testGetAttributesDocument() { + EndpointReferenceType eprt; + try { + eprt = createBESFactoryInstance(); + String bfid = Utilities.extractResourceID(eprt); Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); - String bfId = bfHome.createWSRFServiceInstance(null); + BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); + Thread.sleep(2000); + GetFactoryAttributesDocumentDocument1 req = GetFactoryAttributesDocumentDocument1.Factory.newInstance(); + req.addNewGetFactoryAttributesDocument(); - System.out.println("BESFactory ID: "+bfId); + GetFactoryAttributesDocumentResponseDocument res = bfObj.getAttributesDocument(req); - BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfId); - CreateActivityResponseDocument cresDoc = bfObj - .createActivity(caDoc); - - Home activityHome = Kernel.getKernel() - .getServiceHome("BESActivity"); - String str = Utilities.extractResourceID(cresDoc - .getCreateActivityResponse().getActivityIdentifier()); - System.out.println("BA ResourceID: " + str); - BESActivityImpl activity = (BESActivityImpl) activityHome - .getWSRFServiceInstance(str); - /////////////////////////////////////////// - //checking output////////////////////////// - ////////////////////////////////////////// + logger.info("here is the output: "+res.toString()); - - - - // ///////////////////////////////////////////////////////////////////////// - GetResourcePropertyDocument propDoc = GetResourcePropertyDocument.Factory - .newInstance(); - propDoc.setGetResourceProperty(BESActivity.RPFactoryReference); - GetResourcePropertyResponseDocument resPropDoc = activity - .GetResourceProperty(propDoc); - - - System.out.println("EPR of BF from BA: " - + resPropDoc.getGetResourcePropertyResponse().toString()); - EndpointReferenceDocument eprDoc = EndpointReferenceDocument.Factory.parse(resPropDoc.getGetResourcePropertyResponse().toString()); - - - // //////////////////////////////////////////////////////////////////////// - - System.out.println("In test case: "); - String epr = cresDoc.getCreateActivityResponse() - .getActivityIdentifier().getAddress().getStringValue(); - System.out.println("The epr of Activity: " + epr); - - assertEquals(bfId, Utilities.extractResourceID(eprDoc.getEndpointReference())); - Thread.sleep(3000); - getJobOutcome(activity); } catch (Exception e) { - e.printStackTrace(); - } - - } - - - private void getJobOutcome(BESActivityImpl acImpl){ - FetchOutcomeRequestDocument req = FetchOutcomeRequestDocument.Factory.newInstance(); - req.addNewFetchOutcomeRequest(); - - try { - FetchOutcomeResponseDocument fres = acImpl.fetchOutcome(req); - System.out.println("output of job:::::: "+ fres.toString()); - } catch (BaseFault e) { + logger.info(e.getMessage()); fail(); - System.out.println("Severe : "+e.getMessage()); } - } + + + protected EndpointReferenceType createBESFactoryInstance() throws Exception { + GetBESFactoryInstanceRequestDocument gReq = GetBESFactoryInstanceRequestDocument.Factory + .newInstance(); + gReq.addNewGetBESFactoryInstanceRequest(); + XFireClientFactory proxyMaker = new XFireClientFactory(); + System.out.println("getting proxy object"); + AbstractBESFactory abfObj = (AbstractBESFactory) proxyMaker + .createPlainWSProxy(AbstractBESFactory.class, + "http://localhost:7777/services/AbstractBESFactory", + null); + System.out.println(abfObj.toString()); + GetBESFactoryInstanceResponseDocument gRes = abfObj + .getBESFactoryInstance(gReq); + System.out.println("helol"); + System.out.println(gRes.toString()); + return gRes.getGetBESFactoryInstanceResponse().getBfreference(); + } } This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |
From: <ms...@us...> - 2007-02-07 13:29:46
|
Revision: 231 http://svn.sourceforge.net/unicore/?rev=231&view=rev Author: msmemon Date: 2007-02-07 05:29:38 -0800 (Wed, 07 Feb 2007) Log Message: ----------- - Test Bugs removed Modified Paths: -------------- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestActivity.java omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestBESFactory.java omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestIsAcceptingNewActivitiesRP.java Added Paths: ----------- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivitiesViaFactory.java Removed Paths: ------------- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivityReferenceRP.java Modified: omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestActivity.java =================================================================== --- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestActivity.java 2007-02-07 12:07:34 UTC (rev 230) +++ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestActivity.java 2007-02-07 13:29:38 UTC (rev 231) @@ -2,8 +2,11 @@ import java.io.File; import java.io.IOException; +import java.util.HashMap; import java.util.logging.Logger; +import javax.xml.namespace.QName; + import org.apache.xmlbeans.XmlException; import org.ggf.schemas.bes.x2006.x08.besFactory.ActivityDocumentDocument1; import org.ggf.schemas.bes.x2006.x08.besFactory.ActivityIdentifierDocument; @@ -26,6 +29,7 @@ import de.fzj.unicore.bes.impl.activity.BESActivityHomeImpl; import de.fzj.unicore.bes.impl.activity.BESActivityImpl; import de.fzj.unicore.bes.impl.factory.BESFactoryHomeImpl; +import de.fzj.unicore.bes.impl.factory.BESFactoryImpl; import de.fzj.unicore.wsrflite.Home; import de.fzj.unicore.wsrflite.Kernel; import de.fzj.unicore.wsrflite.utils.Utilities; @@ -85,7 +89,12 @@ // create factory instance Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); - String bfId = bfHome.createWSRFServiceInstance(null); + HashMap<String, Object>initParams = new HashMap<String, Object>(); +// map parameters are necessary to set for besfactory + initParams.put(BESFactoryImpl.INIT_ACTIVITY_FLAG, true); + String strNp = "{http://schemas.ggf.org/bes/2006/08/bes/naming}BasicWSAddressing"; + initParams.put(BESFactoryImpl.INIT_NAMING_PROFILE, new QName(strNp)); + String bfId = bfHome.createWSRFServiceInstance(initParams); System.out.println("BESFactory ID: " + bfId); @@ -175,7 +184,12 @@ // create factory instance Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); - String bfId = bfHome.createWSRFServiceInstance(null); + HashMap<String, Object>initParams = new HashMap<String, Object>(); +// map parameters are necessary to set for besfactory + initParams.put(BESFactoryImpl.INIT_ACTIVITY_FLAG, true); + String strNp = "{http://schemas.ggf.org/bes/2006/08/bes/naming}BasicWSAddressing"; + initParams.put(BESFactoryImpl.INIT_NAMING_PROFILE, new QName(strNp)); + String bfId = bfHome.createWSRFServiceInstance(initParams); System.out.println("BESFactory ID: " + bfId); @@ -222,7 +236,12 @@ // create factory instance Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); - String bfId = bfHome.createWSRFServiceInstance(null); + HashMap<String, Object>initParams = new HashMap<String, Object>(); +// map parameters are necessary to set for besfactory + initParams.put(BESFactoryImpl.INIT_ACTIVITY_FLAG, true); + String strNp = "{http://schemas.ggf.org/bes/2006/08/bes/naming}BasicWSAddressing"; + initParams.put(BESFactoryImpl.INIT_NAMING_PROFILE, new QName(strNp)); + String bfId = bfHome.createWSRFServiceInstance(initParams); System.out.println("BESFactory ID: " + bfId); Modified: omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestBESFactory.java =================================================================== --- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestBESFactory.java 2007-02-07 12:07:34 UTC (rev 230) +++ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/TestBESFactory.java 2007-02-07 13:29:38 UTC (rev 231) @@ -2,6 +2,7 @@ import java.io.File; import java.io.IOException; +import java.util.HashMap; import java.util.logging.Logger; import javax.xml.namespace.QName; @@ -33,7 +34,8 @@ import de.fzj.unicore.bes.impl.activity.BESActivityImpl; import de.fzj.unicore.bes.impl.factory.AbstractBESFactoryImpl; import de.fzj.unicore.bes.impl.factory.BESFactoryHomeImpl; -import de.fzj.unicore.bes.test.factory.TestActivityReferenceRP; +import de.fzj.unicore.bes.impl.factory.BESFactoryImpl; +import de.fzj.unicore.bes.test.factory.TestActivitiesViaFactory; import de.fzj.unicore.wsrflite.BaseFault; import de.fzj.unicore.wsrflite.Home; import de.fzj.unicore.wsrflite.Kernel; @@ -63,7 +65,11 @@ AbstractBESFactory.class, AbstractBESFactoryImpl.class, false); } + + /** + * Creating sample jsdl document for BESFactory + * */ private ActivityDocumentDocument1 prepareActivity() { ActivityDocumentDocument1 aDoc = ActivityDocumentDocument1.Factory @@ -88,66 +94,73 @@ return aDoc; } -// public void testCreateActivity() throws Exception { -// try { -// -// ActivityDocumentDocument1 actDoc = prepareActivity(); -// CreateActivityDocument caDoc = CreateActivityDocument.Factory -// .newInstance(); -// caDoc.addNewCreateActivity().setActivityDocument( -// actDoc.getActivityDocument()); -// -// // create factory instance -// Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); -// String bfId = bfHome.createWSRFServiceInstance(null); -// -// System.out.println("BESFactory ID: " + bfId); -// -// BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfId); -// CreateActivityResponseDocument cresDoc = bfObj -// .createActivity(caDoc); -// -// Home activityHome = Kernel.getKernel() -// .getServiceHome("BESActivity"); -// String str = Utilities.extractResourceID(cresDoc -// .getCreateActivityResponse().getActivityIdentifier()); -// System.out.println("BA ResourceID: " + str); -// BESActivityImpl activity = (BESActivityImpl) activityHome -// .getWSRFServiceInstance(str); -// // ///////////////////////////////////////// -// // checking output////////////////////////// -// // //////////////////////////////////////// -// -// // ///////////////////////////////////////////////////////////////////////// -// GetResourcePropertyDocument propDoc = GetResourcePropertyDocument.Factory -// .newInstance(); -// propDoc.setGetResourceProperty(BESActivity.RPFactoryReference); -// GetResourcePropertyResponseDocument resPropDoc = activity -// .GetResourceProperty(propDoc); -// -// System.out.println("EPR of BF from BA: " -// + resPropDoc.getGetResourcePropertyResponse().toString()); -// EndpointReferenceDocument eprDoc = EndpointReferenceDocument.Factory -// .parse(resPropDoc.getGetResourcePropertyResponse() -// .toString()); -// -// // ///////////////////////////////////////////////////////////////////////// -// -// System.out.println("In test case: "); -// String epr = cresDoc.getCreateActivityResponse() -// .getActivityIdentifier().getAddress().getStringValue(); -// System.out.println("The epr of Activity: " + epr); -// -// assertEquals(bfId, Utilities.extractResourceID(eprDoc -// .getEndpointReference())); -// Thread.sleep(3000); -// getJobOutcome(activity); -// } catch (Exception e) { -// e.printStackTrace(); -// } -// -// } + public void testCreateActivity() throws Exception { + try { + ActivityDocumentDocument1 actDoc = prepareActivity(); + CreateActivityDocument caDoc = CreateActivityDocument.Factory + .newInstance(); + caDoc.addNewCreateActivity().setActivityDocument( + actDoc.getActivityDocument()); + + // create factory instance + Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); + + + HashMap<String, Object>initParams = new HashMap<String, Object>(); +// map parameters are necessary to set for besfactory + initParams.put(BESFactoryImpl.INIT_ACTIVITY_FLAG, true); + String strNp = "{http://schemas.ggf.org/bes/2006/08/bes/naming}BasicWSAddressing"; + initParams.put(BESFactoryImpl.INIT_NAMING_PROFILE, new QName(strNp)); + String bfId = bfHome.createWSRFServiceInstance(initParams); + + System.out.println("BESFactory ID: " + bfId); + + BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfId); + CreateActivityResponseDocument cresDoc = bfObj + .createActivity(caDoc); + + Home activityHome = Kernel.getKernel() + .getServiceHome("BESActivity"); + String str = Utilities.extractResourceID(cresDoc + .getCreateActivityResponse().getActivityIdentifier()); + System.out.println("BA ResourceID: " + str); + BESActivityImpl activity = (BESActivityImpl) activityHome + .getWSRFServiceInstance(str); + // ///////////////////////////////////////// + // checking output////////////////////////// + // //////////////////////////////////////// + + // ///////////////////////////////////////////////////////////////////////// + GetResourcePropertyDocument propDoc = GetResourcePropertyDocument.Factory + .newInstance(); + propDoc.setGetResourceProperty(BESActivity.RPFactoryReference); + GetResourcePropertyResponseDocument resPropDoc = activity + .GetResourceProperty(propDoc); + + System.out.println("EPR of BF from BA: " + + resPropDoc.getGetResourcePropertyResponse().toString()); + EndpointReferenceDocument eprDoc = EndpointReferenceDocument.Factory + .parse(resPropDoc.getGetResourcePropertyResponse() + .toString()); + + // ///////////////////////////////////////////////////////////////////////// + + System.out.println("In test case: "); + String epr = cresDoc.getCreateActivityResponse() + .getActivityIdentifier().getAddress().getStringValue(); + System.out.println("The epr of Activity: " + epr); + + assertEquals(bfId, Utilities.extractResourceID(eprDoc + .getEndpointReference())); + Thread.sleep(3000); + getJobOutcome(activity); + } catch (Exception e) { + e.printStackTrace(); + } + + } + private void getJobOutcome(BESActivityImpl acImpl) { FetchOutcomeRequestDocument req = FetchOutcomeRequestDocument.Factory .newInstance(); @@ -163,29 +176,10 @@ } - public void testGetAttributesDocument() { - EndpointReferenceType eprt; - try { - eprt = createBESFactoryInstance(); - String bfid = Utilities.extractResourceID(eprt); - Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); - BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); - Thread.sleep(2000); - GetFactoryAttributesDocumentDocument1 req = GetFactoryAttributesDocumentDocument1.Factory.newInstance(); - req.addNewGetFactoryAttributesDocument(); - - GetFactoryAttributesDocumentResponseDocument res = bfObj.getAttributesDocument(req); - - logger.info("here is the output: "+res.toString()); - - - } catch (Exception e) { - logger.info(e.getMessage()); - fail(); - } - } - - + + /** + * Creates BESFactory instance via AbstractBESFactory. + * */ protected EndpointReferenceType createBESFactoryInstance() throws Exception { GetBESFactoryInstanceRequestDocument gReq = GetBESFactoryInstanceRequestDocument.Factory .newInstance(); @@ -207,4 +201,33 @@ return gRes.getGetBESFactoryInstanceResponse().getBfreference(); } + + /** + * Tests BESFactory getAttributesDocument method + * + **/ + public void testGetAttributesDocument() { + EndpointReferenceType eprt; + try { + eprt = createBESFactoryInstance(); + String bfid = Utilities.extractResourceID(eprt); + Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); + BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); + + + GetFactoryAttributesDocumentDocument1 req = GetFactoryAttributesDocumentDocument1.Factory.newInstance(); + req.addNewGetFactoryAttributesDocument(); + Thread.sleep(2000); + GetFactoryAttributesDocumentResponseDocument res = bfObj.getAttributesDocument(req); + + logger.info("Attributes Document: "+res.toString()); + + + } catch (Exception e) { + logger.info(e.getMessage()); + fail(); + } + } + + } Copied: omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivitiesViaFactory.java (from rev 160, omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivityReferenceRP.java) =================================================================== --- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivitiesViaFactory.java (rev 0) +++ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivitiesViaFactory.java 2007-02-07 13:29:38 UTC (rev 231) @@ -0,0 +1,186 @@ +package de.fzj.unicore.bes.test.factory; + +import java.io.File; +import java.io.IOException; +import java.util.HashMap; +import java.util.logging.Logger; + +import javax.xml.namespace.QName; + +import org.apache.xmlbeans.XmlCursor; +import org.apache.xmlbeans.XmlException; +import org.ggf.schemas.bes.x2006.x08.besFactory.ActivityDocumentDocument1; +import org.ggf.schemas.bes.x2006.x08.besFactory.CreateActivityDocument; +import org.ggf.schemas.bes.x2006.x08.besFactory.CreateActivityResponseDocument; +import org.ggf.schemas.jsdl.x2005.x11.jsdl.JobDefinitionDocument; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyDocument; +import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyResponseDocument; +import de.fzj.unicore.bes.BESActivity; +import de.fzj.unicore.bes.BESFactory; +import de.fzj.unicore.bes.impl.activity.BESActivityHomeImpl; +import de.fzj.unicore.bes.impl.activity.BESActivityImpl; +import de.fzj.unicore.bes.impl.factory.AbstractBESFactoryImpl; +import de.fzj.unicore.bes.impl.factory.BESFactoryHomeImpl; +import de.fzj.unicore.bes.impl.factory.BESFactoryImpl; +import de.fzj.unicore.wsrflite.Home; +import de.fzj.unicore.wsrflite.Kernel; +import de.fzj.unicore.wsrflite.utils.Utilities; +import de.fzj.unicore.wsrflite.xfire.JettyTestCase; +import de.fzj.unicore.wsrflite.xfire.XFireKernel; + +public class TestActivitiesViaFactory extends JettyTestCase { + + private static Logger logger = Logger + .getLogger(TestActivitiesViaFactory.class.getName()); + + @Override + protected void addServices() throws Exception { + XFireKernel.exposeAsService("BESFactory", BESFactory.class, + BESFactoryHomeImpl.class, true); + + XFireKernel.exposeAsService("BESActivity", BESActivity.class, + BESActivityHomeImpl.class, true); + + } + + private ActivityDocumentDocument1 prepareActivity() { + ActivityDocumentDocument1 aDoc = ActivityDocumentDocument1.Factory + .newInstance(); + + try { + JobDefinitionDocument jDoc = JobDefinitionDocument.Factory + .parse(new File( + "/home/m.memon/workspace/ogsa-bes/src/test/resources/jsdlinstance.xml")); + aDoc.addNewActivityDocument().setJobDefinition( + jDoc.getJobDefinition()); + + logger.info("Comeon In Test test: " + aDoc.toString()); + } catch (XmlException e) { + logger.severe(e.getMessage()); + fail(); + } catch (IOException e) { + logger.severe(e.getMessage()); + fail(); + } + + return aDoc; + } + + public void testGetActivityReferences() { + + try { + ActivityDocumentDocument1 acDoc = ActivityDocumentDocument1.Factory + .newInstance(); + Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); + AbstractBESFactoryImpl abs = new AbstractBESFactoryImpl(); + + HashMap<String, Object> initParams = new HashMap<String, Object>(); + initParams.put(BESFactoryImpl.INIT_ACTIVITY_FLAG, true); + initParams + .put(BESFactoryImpl.INIT_NAMING_PROFILE, + new QName("{http://schemas.ggf.org/bes/2006/08/bes/naming}BasicWSAddressing")); + + String bfId = bfHome.createWSRFServiceInstance(initParams); + BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfId); + CreateActivityDocument caDoc = CreateActivityDocument.Factory + .newInstance(); + caDoc.addNewCreateActivity().setActivityDocument( + prepareActivity().getActivityDocument()); + CreateActivityResponseDocument cresDoc = bfObj + .createActivity(caDoc); + CreateActivityResponseDocument cresDoc2 = bfObj + .createActivity(caDoc); + CreateActivityResponseDocument cresDoc3 = bfObj + .createActivity(caDoc); + CreateActivityResponseDocument cresDoc4 = bfObj + .createActivity(caDoc); + + Home activityHome = Kernel.getKernel() + .getServiceHome("BESActivity"); + String str = Utilities.extractResourceID(cresDoc + .getCreateActivityResponse().getActivityIdentifier()); + System.out.println("BA ResourceID 1: " + str); + BESActivityImpl activity = (BESActivityImpl) activityHome + .getWSRFServiceInstance(str); + + String str2 = Utilities.extractResourceID(cresDoc2 + .getCreateActivityResponse().getActivityIdentifier()); + System.out.println("BA ResourceID 2: " + str2); + BESActivityImpl activity2 = (BESActivityImpl) activityHome + .getWSRFServiceInstance(str2); + + String str3 = Utilities.extractResourceID(cresDoc3 + .getCreateActivityResponse().getActivityIdentifier()); + System.out.println("BA ResourceID 3: " + str3); + BESActivityImpl activity3 = (BESActivityImpl) activityHome + .getWSRFServiceInstance(str3); + + String str4 = Utilities.extractResourceID(cresDoc4 + .getCreateActivityResponse().getActivityIdentifier()); + System.out.println("BA ResourceID 4: " + str4); + BESActivityImpl activity4 = (BESActivityImpl) activityHome + .getWSRFServiceInstance(str4); + + GetResourcePropertyDocument grpDoc = GetResourcePropertyDocument.Factory + .newInstance(); + grpDoc.setGetResourceProperty(BESFactory.RPActivityReference); + + GetResourcePropertyResponseDocument res = bfObj + .GetResourceProperty(grpDoc); + + logger.info("activity Reference RP: " + res.toString()); + assertNotNull(res.toString().contains(activity.getUniqueID())); + assertNotNull(res.toString().contains(activity2.getUniqueID())); + assertNotNull(res.toString().contains(activity3.getUniqueID())); + assertNotNull(res.toString().contains(activity4.getUniqueID())); + + + + + + + } catch (Exception e) { + logger.severe("Test Fails: " + e.getCause().toString()); + fail(); + + } + + } + + + public void testTotalNumberOfActivities() throws Exception { + ActivityDocumentDocument1 acDoc = ActivityDocumentDocument1.Factory + .newInstance(); + Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); + HashMap<String, Object> initParams = new HashMap<String, Object>(); + initParams.put(BESFactoryImpl.INIT_ACTIVITY_FLAG, true); + initParams + .put(BESFactoryImpl.INIT_NAMING_PROFILE, + new QName("{http://schemas.ggf.org/bes/2006/08/bes/naming}BasicWSAddressing")); + String bfId = bfHome.createWSRFServiceInstance(initParams); + BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfId); + CreateActivityDocument caDoc = CreateActivityDocument.Factory + .newInstance(); + caDoc.addNewCreateActivity().setActivityDocument( + prepareActivity().getActivityDocument()); + CreateActivityResponseDocument cresDoc = bfObj.createActivity(caDoc); + cresDoc = bfObj.createActivity(caDoc); + cresDoc = bfObj.createActivity(caDoc); + cresDoc = bfObj.createActivity(caDoc); + + GetResourcePropertyDocument grpDoc = GetResourcePropertyDocument.Factory + .newInstance(); + grpDoc.setGetResourceProperty(BESFactory.RPTotalNumberOfActivities); + + GetResourcePropertyResponseDocument res = bfObj + .GetResourceProperty(grpDoc); + logger.info("number of activities rp:" + res.toString()); + XmlCursor cursor = res.newCursor(); + cursor.toFirstChild(); + cursor.toFirstChild(); + + assertEquals(4, Integer.parseInt(cursor.getTextValue())); + + } + +} Deleted: omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivityReferenceRP.java =================================================================== --- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivityReferenceRP.java 2007-02-07 12:07:34 UTC (rev 230) +++ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestActivityReferenceRP.java 2007-02-07 13:29:38 UTC (rev 231) @@ -1,162 +0,0 @@ -package de.fzj.unicore.bes.test.factory; - -import java.io.File; -import java.io.IOException; -import java.util.logging.Logger; - -import org.apache.xmlbeans.XmlCursor; -import org.apache.xmlbeans.XmlException; -import org.ggf.schemas.bes.x2006.x08.besFactory.ActivityDocumentDocument1; -import org.ggf.schemas.bes.x2006.x08.besFactory.CreateActivityDocument; -import org.ggf.schemas.bes.x2006.x08.besFactory.CreateActivityResponseDocument; -import org.ggf.schemas.jsdl.x2005.x11.jsdl.JobDefinitionDocument; -import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyDocument; -import org.oasisOpen.docs.wsrf.rp2.GetResourcePropertyResponseDocument; -import de.fzj.unicore.bes.BESActivity; -import de.fzj.unicore.bes.BESFactory; -import de.fzj.unicore.bes.impl.activity.BESActivityHomeImpl; -import de.fzj.unicore.bes.impl.activity.BESActivityImpl; -import de.fzj.unicore.bes.impl.factory.BESFactoryHomeImpl; -import de.fzj.unicore.wsrflite.Home; -import de.fzj.unicore.wsrflite.Kernel; -import de.fzj.unicore.wsrflite.utils.Utilities; -import de.fzj.unicore.wsrflite.xfire.JettyTestCase; -import de.fzj.unicore.wsrflite.xfire.XFireKernel; - -public class TestActivityReferenceRP extends JettyTestCase { - - private static Logger logger = Logger - .getLogger(TestActivityReferenceRP.class.getName()); - - @Override - protected void addServices() throws Exception { - XFireKernel.exposeAsService("BESFactory", BESFactory.class, - BESFactoryHomeImpl.class, true); - - XFireKernel.exposeAsService("BESActivity", BESActivity.class, - BESActivityHomeImpl.class, true); - - } - - private ActivityDocumentDocument1 prepareActivity() { - ActivityDocumentDocument1 aDoc = ActivityDocumentDocument1.Factory - .newInstance(); - - try { - JobDefinitionDocument jDoc = JobDefinitionDocument.Factory - .parse(new File( - "/home/m.memon/workspace/ogsa-bes/src/test/resources/jsdlinstance.xml")); - aDoc.addNewActivityDocument().setJobDefinition( - jDoc.getJobDefinition()); - - logger.info("Comeon In Test test: " + aDoc.toString()); - } catch (XmlException e) { - logger.severe(e.getMessage()); - fail(); - } catch (IOException e) { - logger.severe(e.getMessage()); - fail(); - } - - return aDoc; - } - - public void testGetActivityReferences() { - - try { - ActivityDocumentDocument1 acDoc = ActivityDocumentDocument1.Factory - .newInstance(); - Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); - String bfId = bfHome.createWSRFServiceInstance(null); - BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfId); - CreateActivityDocument caDoc = CreateActivityDocument.Factory - .newInstance(); - caDoc.addNewCreateActivity().setActivityDocument( - prepareActivity().getActivityDocument()); - CreateActivityResponseDocument cresDoc = bfObj - .createActivity(caDoc); - CreateActivityResponseDocument cresDoc2 = bfObj - .createActivity(caDoc); - CreateActivityResponseDocument cresDoc3 = bfObj - .createActivity(caDoc); - CreateActivityResponseDocument cresDoc4 = bfObj - .createActivity(caDoc); - - Home activityHome = Kernel.getKernel() - .getServiceHome("BESActivity"); - String str = Utilities.extractResourceID(cresDoc - .getCreateActivityResponse().getActivityIdentifier()); - System.out.println("BA ResourceID 1: " + str); - BESActivityImpl activity = (BESActivityImpl) activityHome - .getWSRFServiceInstance(str); - - String str2 = Utilities.extractResourceID(cresDoc2 - .getCreateActivityResponse().getActivityIdentifier()); - System.out.println("BA ResourceID 2: " + str2); - BESActivityImpl activity2 = (BESActivityImpl) activityHome - .getWSRFServiceInstance(str2); - - String str3 = Utilities.extractResourceID(cresDoc3 - .getCreateActivityResponse().getActivityIdentifier()); - System.out.println("BA ResourceID 3: " + str3); - BESActivityImpl activity3 = (BESActivityImpl) activityHome - .getWSRFServiceInstance(str3); - - String str4 = Utilities.extractResourceID(cresDoc4 - .getCreateActivityResponse().getActivityIdentifier()); - System.out.println("BA ResourceID 4: " + str4); - BESActivityImpl activity4 = (BESActivityImpl) activityHome - .getWSRFServiceInstance(str4); - - GetResourcePropertyDocument grpDoc = GetResourcePropertyDocument.Factory - .newInstance(); - grpDoc.setGetResourceProperty(BESFactory.RPActivityReference); - - GetResourcePropertyResponseDocument res = bfObj - .GetResourceProperty(grpDoc); - - logger.info("activity Reference RP: " + res.toString()); - assertNotNull(res.toString().contains(activity.getUniqueID())); - assertNotNull(res.toString().contains(activity2.getUniqueID())); - assertNotNull(res.toString().contains(activity3.getUniqueID())); - assertNotNull(res.toString().contains(activity4.getUniqueID())); - - } catch (Exception e) { - fail(); - logger.severe("Test Fails: " + e.getMessage()); - } - - } - - public void testTotalNumberOfActivities() throws Exception { - ActivityDocumentDocument1 acDoc = ActivityDocumentDocument1.Factory - .newInstance(); - Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); - String bfId = bfHome.createWSRFServiceInstance(null); - BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfId); - CreateActivityDocument caDoc = CreateActivityDocument.Factory - .newInstance(); - caDoc.addNewCreateActivity().setActivityDocument( - prepareActivity().getActivityDocument()); - CreateActivityResponseDocument cresDoc = bfObj.createActivity(caDoc); - cresDoc = bfObj.createActivity(caDoc); - cresDoc = bfObj.createActivity(caDoc); - cresDoc = bfObj.createActivity(caDoc); - - GetResourcePropertyDocument grpDoc = GetResourcePropertyDocument.Factory - .newInstance(); - grpDoc.setGetResourceProperty(BESFactory.RPTotalNumberOfActivities); - - GetResourcePropertyResponseDocument res = bfObj - .GetResourceProperty(grpDoc); - logger.info("number of activities rp:" + res.toString()); - XmlCursor cursor = res.newCursor(); - cursor.toFirstChild(); - cursor.toFirstChild(); - - assertEquals(4, Integer.parseInt(cursor.getTextValue())); - } - - - -} Modified: omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestIsAcceptingNewActivitiesRP.java =================================================================== --- omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestIsAcceptingNewActivitiesRP.java 2007-02-07 12:07:34 UTC (rev 230) +++ omii-europe/ogsa-bes/trunk/src/test/java/de/fzj/unicore/bes/test/factory/TestIsAcceptingNewActivitiesRP.java 2007-02-07 13:29:38 UTC (rev 231) @@ -49,40 +49,41 @@ AbstractBESFactory.class, AbstractBESFactoryImpl.class, false); } - public void testGetActivityFlag() { - EndpointReferenceType eprt; - try { - eprt = createBESFactoryInstance(); - String bfid = Utilities.extractResourceID(eprt); - Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); - BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); - - GetResourcePropertyDocument grpDoc = GetResourcePropertyDocument.Factory - .newInstance(); - grpDoc - .setGetResourceProperty(BESFactory.RPIsAcceptingNewActivities); - - GetResourcePropertyResponseDocument res = bfObj - .GetResourceProperty(grpDoc); - - Boolean b = new Boolean(BES - .getProperty(BES.IS_ACCEPTING_NEW_ACTIVITIES)); - - XmlCursor cursor = res.newCursor(); - cursor.toFirstChild(); - cursor.toFirstChild(); - - assertEquals(b.toString(), cursor.getTextValue()); - - logger.info("IsAccepting new activities: " + res.toString()); - } catch (Exception e) { - logger.info(e.getMessage()); - fail(); - } - - } + public void testGetActivityFlag() { + EndpointReferenceType eprt; + try { + eprt = createBESFactoryInstance(); + String bfid = Utilities.extractResourceID(eprt); + Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); + BESFactory bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); + + GetResourcePropertyDocument grpDoc = GetResourcePropertyDocument.Factory + .newInstance(); + grpDoc + .setGetResourceProperty(BESFactory.RPIsAcceptingNewActivities); + + GetResourcePropertyResponseDocument res = bfObj + .GetResourceProperty(grpDoc); + + Boolean b = new Boolean(BES + .getProperty(BES.IS_ACCEPTING_NEW_ACTIVITIES)); + + XmlCursor cursor = res.newCursor(); + cursor.toFirstChild(); + cursor.toFirstChild(); + + assertEquals(b.toString(), cursor.getTextValue()); + + logger.info("IsAccepting new activities: " + res.toString()); + } catch (Exception e) { + logger.info(e.getMessage()); + fail(); + } + } + + private EndpointReferenceType createBESFactoryInstance() throws Exception { GetBESFactoryInstanceRequestDocument gReq = GetBESFactoryInstanceRequestDocument.Factory .newInstance(); @@ -100,41 +101,39 @@ .getBESFactoryInstance(gReq); System.out.println("helol"); System.out.println(gRes.toString()); - - + return gRes.getGetBESFactoryInstanceResponse().getBfreference(); } - - + // checks if flag is false -// private void testCreateActivity() { -// EndpointReferenceType eprt; -// BESFactory bfObj = null; -// try{ -// eprt = createBESFactoryInstance(); -// String bfid = Utilities.extractResourceID(eprt); -// Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); -// bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); -// } -// catch(Exception e){ -// logger.severe(e.getMessage()); -// } -// CreateActivityDocument caDoc = CreateActivityDocument.Factory -// .newInstance(); -// caDoc.addNewCreateActivity().setActivityDocument( -// prepareActivity().getActivityDocument()); -// try { -// CreateActivityResponseDocument cresDoc = bfObj.createActivity(caDoc); -// } catch (NotAcceptingNewActivitiesFault e) { -// logger.severe(e.getMessage()); -// assertTrue(true); -// } -// -// -// -// -// -// } + // private void testCreateActivity() { + // EndpointReferenceType eprt; + // BESFactory bfObj = null; + // try{ + // eprt = createBESFactoryInstance(); + // String bfid = Utilities.extractResourceID(eprt); + // Home bfHome = Kernel.getKernel().getServiceHome("BESFactory"); + // bfObj = (BESFactory) bfHome.getWSRFServiceInstance(bfid); + // } + // catch(Exception e){ + // logger.severe(e.getMessage()); + // } + // CreateActivityDocument caDoc = CreateActivityDocument.Factory + // .newInstance(); + // caDoc.addNewCreateActivity().setActivityDocument( + // prepareActivity().getActivityDocument()); + // try { + // CreateActivityResponseDocument cresDoc = bfObj.createActivity(caDoc); + // } catch (NotAcceptingNewActivitiesFault e) { + // logger.severe(e.getMessage()); + // assertTrue(true); + // } + // + // + // + // + // + // } private ActivityDocumentDocument1 prepareActivity() { ActivityDocumentDocument1 aDoc = ActivityDocumentDocument1.Factory @@ -147,7 +146,7 @@ aDoc.addNewActivityDocument().setJobDefinition( jDoc.getJobDefinition()); - logger.info("Comeon In Test test: " + aDoc.toString()); + logger.info("JSDL Instance Activity: " + aDoc.toString()); } catch (XmlException e) { logger.severe(e.getMessage()); fail(); This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site. |