package org.objectweb.celtix.bus.ws.rm;
import java.io.IOException;
import javax.wsdl.WSDLException;
import org.objectweb.celtix.Bus;
import org.objectweb.celtix.bindings.DataBindingCallback;
import org.objectweb.celtix.bindings.Request;
import org.objectweb.celtix.bus.bindings.TestClientTransport;
import org.objectweb.celtix.bus.bindings.soap.SOAPClientBinding;
import org.objectweb.celtix.transports.ClientTransport;
import org.objectweb.celtix.transports.Transport;
import org.objectweb.celtix.ws.addressing.EndpointReferenceType;
public class TestSoapClientBinding extends SOAPClientBinding {
boolean sent;
public TestSoapClientBinding(Bus b, EndpointReferenceType ref) throws WSDLException, IOException {
super(b, ref);
}
protected ClientTransport createTransport(EndpointReferenceType ref)
throws WSDLException, IOException {
return new TestClientTransport(bus, ref);
}
public TestClientTransport getClientTransport() throws IOException {
return (TestClientTransport)getTransport();
}
public Transport retrieveTransport() {
try {
return getTransport();
} catch (IOException ioe) {
return null;
}
}
public void send(Request request, DataBindingCallback callback)
throws IOException {
sent = true;
}
boolean isSent() {
return sent;
}
/*
class TestClientTransport implements ClientTransport {
private InputStreamMessageContext istreamCtx;
public TestClientTransport(Bus b, EndpointReferenceType ref) {
}
public EndpointReferenceType getTargetEndpoint() {
return null;
}
public EndpointReferenceType getDecoupledEndpoint() throws IOException {
return null;
}
public Port getPort() {
return null;
}
public OutputStreamMessageContext createOutputStreamContext(MessageContext context)
throws IOException {
return new TestOutputStreamContext(null, context);
}
public void finalPrepareOutputStreamContext(OutputStreamMessageContext context) throws IOException {
}
public void invokeOneway(OutputStreamMessageContext context) throws IOException {
//nothing to do
}
public InputStreamMessageContext invoke(OutputStreamMessageContext context) throws IOException {
return istreamCtx;
}
public Future<InputStreamMessageContext> invokeAsync(OutputStreamMessageContext context, Executor ex)
throws IOException {
return null;
}
public void shutdown() {
//nothing to do
}
public void setInputStreamMessageContext(InputStreamMessageContext i) {
istreamCtx = i;
}
}
*/
}