Package org.springframework.ws.transport.http

Class HttpExchangeConnection

java.lang.Object

org.springframework.ws.transport.AbstractWebServiceConnection

org.springframework.ws.transport.AbstractReceiverConnection

org.springframework.ws.transport.http.HttpExchangeConnection

All Implemented Interfaces:

AutoCloseable, EndpointAwareWebServiceConnection, FaultAwareWebServiceConnection, HeadersAwareReceiverWebServiceConnection, WebServiceConnection

public class HttpExchangeConnection
extends AbstractReceiverConnection
implements EndpointAwareWebServiceConnection, FaultAwareWebServiceConnection

Implementation of WebServiceConnection that is based on the Java 6 HttpServer HttpExchange.

Since:

1.5.0

Author:

Arjen Poutsma, Greg Turnquist

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	HttpExchangeConnection(com.sun.net.httpserver.HttpExchange httpExchange)	Constructs a new exchange connection with the given HttpExchange.

Method Summary

Modifier and Type	Method	Description
void	addResponseHeader(String name, String value)	Adds a response header with the given name and value.
void	endpointNotFound()	Called when an endpoint is not found.
String	getErrorMessage()	Returns the error message.
com.sun.net.httpserver.HttpExchange	getHttpExchange()	Returns the HttpExchange for this connection.
Iterator<String>	getRequestHeaderNames()	Returns an iteration over all the header names this request contains.
Iterator<String>	getRequestHeaders(String name)	Returns an iteration over all the string values of the specified header.
protected InputStream	getRequestInputStream()	Returns the input stream to read the response from.
protected OutputStream	getResponseOutputStream()	Returns the output stream to write the request to.
URI	getUri()	Returns the URI for this connection.
boolean	hasError()	Indicates whether this connection has an error.
boolean	hasFault()	Indicates whether this connection received a fault.
void	onClose()	Template method invoked from AbstractWebServiceConnection.close().
protected void	onSendAfterWrite(WebServiceMessage message)	Called after the given message has been written to the TransportOutputStream.
void	setFault(boolean fault)	Deprecated.
void	setFaultCode(QName faultCode)	Sets a specific fault code.

Methods inherited from class org.springframework.ws.transport.AbstractReceiverConnection

createTransportInputStream, createTransportOutputStream

Methods inherited from class org.springframework.ws.transport.AbstractWebServiceConnection

close, onReceiveAfterRead, onReceiveBeforeRead, onSendBeforeWrite, receive, send

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.ws.transport.WebServiceConnection

close, receive, send

Constructor Details

HttpExchangeConnection

protected HttpExchangeConnection(com.sun.net.httpserver.HttpExchange httpExchange)

Constructs a new exchange connection with the given HttpExchange.

Method Details

getHttpExchange

public com.sun.net.httpserver.HttpExchange getHttpExchange()

Returns the HttpExchange for this connection.

getUri

public URI getUri()
           throws URISyntaxException

Description copied from interface: WebServiceConnection

Returns the URI for this connection.

Specified by:

getUri in interface WebServiceConnection

Throws:

URISyntaxException

endpointNotFound

public void endpointNotFound()

Description copied from interface: EndpointAwareWebServiceConnection

Called when an endpoint is not found.

Specified by:

endpointNotFound in interface EndpointAwareWebServiceConnection

hasError

public boolean hasError()
                 throws IOException

Description copied from interface: WebServiceConnection

Indicates whether this connection has an error. Typically, error detection is done by inspecting connection error codes, etc.

Specified by:

hasError in interface WebServiceConnection

Returns:

true if this connection has an error; false otherwise.

Throws:

IOException

getErrorMessage

public String getErrorMessage()
                       throws IOException

Description copied from interface: WebServiceConnection

Returns the error message.

Specified by:

getErrorMessage in interface WebServiceConnection

Returns:

the connection error message, if any; returns null when no error is present

Throws:

IOException

See Also:

• WebServiceConnection.hasError()

getRequestHeaderNames

public Iterator<String> getRequestHeaderNames()
                                       throws IOException

Description copied from interface: HeadersAwareReceiverWebServiceConnection

Returns an iteration over all the header names this request contains. Returns an empty Iterator if there are no headers.

Specified by:

getRequestHeaderNames in interface HeadersAwareReceiverWebServiceConnection

Throws:

IOException

getRequestHeaders

public Iterator<String> getRequestHeaders(String name)
                                   throws IOException

Description copied from interface: HeadersAwareReceiverWebServiceConnection

Returns an iteration over all the string values of the specified header. Returns an empty Iterator if there are no headers of the specified name.

Specified by:

getRequestHeaders in interface HeadersAwareReceiverWebServiceConnection

Throws:

IOException

getRequestInputStream

protected InputStream getRequestInputStream()
                                     throws IOException

Description copied from class: AbstractReceiverConnection

Returns the input stream to read the response from.

Specified by:

getRequestInputStream in class AbstractReceiverConnection

Throws:

IOException

addResponseHeader

public void addResponseHeader(String name,
 String value)
                       throws IOException

Description copied from interface: HeadersAwareReceiverWebServiceConnection

Adds a response header with the given name and value. This method can be called multiple times, to allow for headers with multiple values.

Specified by:

addResponseHeader in interface HeadersAwareReceiverWebServiceConnection

Parameters:

name - the name of the header

value - the value of the header

Throws:

IOException

getResponseOutputStream

protected OutputStream getResponseOutputStream()
                                        throws IOException

Description copied from class: AbstractReceiverConnection

Returns the output stream to write the request to.

Specified by:

getResponseOutputStream in class AbstractReceiverConnection

Throws:

IOException

onSendAfterWrite

protected void onSendAfterWrite(WebServiceMessage message)
                         throws IOException

Description copied from class: AbstractWebServiceConnection

Called after the given message has been written to the TransportOutputStream. Called from AbstractWebServiceConnection.send(WebServiceMessage).

Default implementation does nothing.

Overrides:

onSendAfterWrite in class AbstractWebServiceConnection

Parameters:

message - the message

Throws:

IOException - when an I/O exception occurs

onClose

public void onClose()
             throws IOException

Description copied from class: AbstractReceiverConnection

Template method invoked from AbstractWebServiceConnection.close(). Default implementation is empty.

Overrides:

onClose in class AbstractReceiverConnection

Throws:

IOException - if an I/O error occurs when closing this connection

hasFault

public boolean hasFault()
                 throws IOException

Description copied from interface: FaultAwareWebServiceConnection

Indicates whether this connection received a fault.

Typically implemented by looking at an HTTP status code.

Specified by:

hasFault in interface FaultAwareWebServiceConnection

Returns:

true if this connection received a fault; false otherwise.

Throws:

IOException - in case of I/O errors

setFault

@Deprecated
public void setFault(boolean fault)
              throws IOException

Deprecated.

Description copied from interface: FaultAwareWebServiceConnection

Sets whether this connection will send a fault.

Typically implemented by setting an HTTP status code.

Specified by:

setFault in interface FaultAwareWebServiceConnection

Parameters:

fault - true if this will send a fault; false otherwise.

Throws:

IOException - in case of I/O errors

setFaultCode

public void setFaultCode(QName faultCode)
                  throws IOException

Description copied from interface: FaultAwareWebServiceConnection

Sets a specific fault code.

Typically implemented by setting an HTTP status code.

Specified by:

setFaultCode in interface FaultAwareWebServiceConnection

Parameters:

faultCode - the fault code to be set on the connection, or null for no fault.

Throws:

IOException - in case of I/O errors