From: Steve L. <st...@us...> - 2006-06-08 03:43:59
|
Update of /cvsroot/smartfrog/projects/alpine/prototype/M32/src/java/org/smartfrog/projects/alpine/transport In directory sc8-pr-cvs8.sourceforge.net:/tmp/cvs-serv10097/alpine/prototype/M32/src/java/org/smartfrog/projects/alpine/transport Modified Files: Session.java Log Message: message ids are uuids Index: Session.java =================================================================== RCS file: /cvsroot/smartfrog/projects/alpine/prototype/M32/src/java/org/smartfrog/projects/alpine/transport/Session.java,v retrieving revision 1.6 retrieving revision 1.7 diff -C2 -d -r1.6 -r1.7 *** Session.java 6 Jun 2006 16:11:53 -0000 1.6 --- Session.java 7 Jun 2006 15:51:15 -0000 1.7 *************** *** 26,33 **** --- 26,36 ---- import org.smartfrog.projects.alpine.core.MessageContext; import org.smartfrog.projects.alpine.om.soap11.MessageDocument; + import org.smartfrog.projects.alpine.om.base.SoapElement; import org.smartfrog.projects.alpine.wsa.AddressDetails; import org.smartfrog.projects.alpine.wsa.AlpineEPR; import org.smartfrog.projects.alpine.wsa.MessageIDSource; + import javax.xml.namespace.QName; + /** * This represents an ongoing conversation with a single host/endpoint. Stuff like *************** *** 89,92 **** --- 92,99 ---- } + protected Log getLog() { + return log; + } + public String getRole() { return role; *************** *** 200,204 **** * @return the transmission, which can be waited on */ ! public Transmission queue(String action, Element payload) { Transmission tx = createTransmission(action, payload); queue.transmit(tx); --- 207,211 ---- * @return the transmission, which can be waited on */ ! public Transmission queue(String action, SoapElement payload) { Transmission tx = createTransmission(action, payload); queue.transmit(tx); *************** *** 216,222 **** * @return the transmission, which can be waited on */ ! public Transmission queue(Element payload) { ! return queue(null, payload); } } --- 223,241 ---- * @return the transmission, which can be waited on */ ! public Transmission queue(SoapElement payload) { ! return queue(getSoapAction(payload), payload); } + /** + * Override point for things to get their own soapAction + * @param request + * @return + */ + public String getSoapAction(QName request) { + return request.getNamespaceURI()+"/"+request.getLocalPart(); + } + + public String getSoapAction(SoapElement request) { + return getSoapAction(request.getQName()); + } } |