From: Steve L. <st...@us...> - 2005-09-28 15:16:40
|
Update of /cvsroot/smartfrog/core/components/deployapi/src/org/smartfrog/services/deployapi/transport/endpoints In directory sc8-pr-cvs1.sourceforge.net:/tmp/cvs-serv1738/components/deployapi/src/org/smartfrog/services/deployapi/transport/endpoints Modified Files: SystemEndpoint.java Log Message: fixed WS-A problems. Index: SystemEndpoint.java =================================================================== RCS file: /cvsroot/smartfrog/core/components/deployapi/src/org/smartfrog/services/deployapi/transport/endpoints/SystemEndpoint.java,v retrieving revision 1.11 retrieving revision 1.12 diff -C2 -d -r1.11 -r1.12 *** SystemEndpoint.java 27 Sep 2005 23:31:50 -0000 1.11 --- SystemEndpoint.java 28 Sep 2005 15:16:30 -0000 1.12 *************** *** 24,27 **** --- 24,29 ---- import org.apache.axis2.context.MessageContext; import org.apache.axis2.om.OMElement; + import org.apache.commons.logging.Log; + import org.apache.commons.logging.LogFactory; import org.ggf.xbeans.cddlm.api.InitializeRequestDocument; import org.ggf.xbeans.cddlm.api.InitializeResponseDocument; *************** *** 30,33 **** --- 32,37 ---- import org.smartfrog.services.deployapi.binding.bindings.InitializeBinding; import org.smartfrog.services.deployapi.engine.Job; + import org.smartfrog.services.deployapi.engine.JobRepository; + import org.smartfrog.services.deployapi.engine.ServerInstance; import org.smartfrog.services.deployapi.system.Constants; import org.smartfrog.services.deployapi.system.Utils; *************** *** 51,59 **** /* * System EPR ! */ public class SystemEndpoint extends WsrfEndpoint { ! /** * deliver a message --- 55,64 ---- /* * System EPR ! */; public class SystemEndpoint extends WsrfEndpoint { ! Log log= LogFactory.getLog(SystemEndpoint.class); ! /** * deliver a message *************** *** 83,107 **** } /** * Look up a job * @param inMessage ! * @return */ protected Job lookupJob(MessageContext inMessage) { EndpointReference to = inMessage.getTo(); ! String address = to.getAddress(); ! URL url=null; ! try { ! url = new URL(address); ! } catch (MalformedURLException e) { ! throw new RuntimeException("Couldn't turn an addr into a URL "+address,e); ! } ! String query = url.getRef(); ! if(query==null) { ! return null; ! } ! ! FaultRaiser.throwNotImplemented(); ! return null; } --- 88,103 ---- } + /** * Look up a job * @param inMessage ! * @return a job or null for no job matching that query found ! * @throws BaseException if the args are bad */ protected Job lookupJob(MessageContext inMessage) { + JobRepository jobs = ServerInstance.currentInstance().getJobs(); EndpointReference to = inMessage.getTo(); ! Job job=jobs.lookupJobFromEndpointer(to); ! return job; } |