| Methods Summary |
|---|
| public static java.lang.String | getAcksTo()Accessor for the AcksTo field.
return acksTo;
|
| public static com.sun.xml.ws.rm.protocol.CreateSequenceResponseElement | getCreateSequenceResponse(java.lang.String messageId)
CreateSequenceResponseElement ret = null;
synchronized (knownIds) {
if (!knownIds.keySet().contains(messageId)) {
knownIds.put(messageId, null);
}
while (null == (ret = knownIds.get(messageId))) {
try {
knownIds.wait();
} catch (InterruptedException e){}
}
}
return ret;
|
| public static void | handleAcknowledgement(com.sun.xml.ws.rm.protocol.SequenceAcknowledgementElement el)
//probably no need for synchronization here. The element was initialized at the
//endpoint using a sequenceid generated by the endpoint that made it back to
//the client. That means that getCreateSequenceResponse has returned long ago.
String id = el.getId();
ClientOutboundSequence seq = RMSource.getRMSource().getOutboundSequence(id);
if (id == null) {
throw new InvalidSequenceException(String.format(Constants.UNKNOWN_SEQUENCE_TEXT,id),id);
}
seq.handleAckResponse(el);
|
| public static void | setCreateSequenceResponse(java.lang.String messageId, com.sun.xml.ws.rm.protocol.CreateSequenceResponseElement csrElement)
synchronized (knownIds) {
knownIds.put(messageId, csrElement);
knownIds.notifyAll();
}
|
| public static void | start(java.lang.String newAcksTo)
/*
if (!acksTo.equals(anonymous) && !newAcksTo.equals(acksTo)) {
throw new UnsupportedOperationException("Cannot change non-anonymous acksTo");
}
if (acksTo.equals(anonymous)) {
acksTo = newAcksTo;
//start our endpoint listening on the given URI
BindingID binding = BindingID.parse(SOAPBinding.SOAP12HTTP_BINDING) ;
endpoint = new EndpointImpl(binding, new DummyProvider());
endpoint.publish(acksTo);
}
*/
|
| public static void | stop()
/*
if (endpoint != null) {
endpoint.stop();
}
*/
|
