org.springframework.ws.transport.jms

Class JmsSenderConnection

java.lang.Object

org.springframework.ws.transport.AbstractWebServiceConnection

org.springframework.ws.transport.AbstractSenderConnection

org.springframework.ws.transport.jms.JmsSenderConnection

All Implemented Interfaces:

AutoCloseable, HeadersAwareSenderWebServiceConnection, WebServiceConnection

public class JmsSenderConnection
extends AbstractSenderConnection

Implementation of WebServiceConnection that is used for client-side JMS access. Exposes a BytesMessage request and response message.

Since:

1.5.0

Author:

Arjen Poutsma, Greg Turnquist

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JmsSenderConnection(javax.jms.ConnectionFactory connectionFactory, javax.jms.Connection connection, javax.jms.Session session, javax.jms.Destination requestDestination, javax.jms.Message requestMessage) Constructs a new JMS connection with the given parameters.

Method Summary

Modifier and Type	Method and Description
void	addRequestHeader(String name, String value) Adds a request header with the given name and value.
String	getErrorMessage() Returns the error message.
javax.jms.Message	getRequestMessage() Returns the request message for this connection.
protected OutputStream	getRequestOutputStream() Returns the output stream to write the request to.
Iterator<String>	getResponseHeaderNames() Returns an iteration over all the header names this request contains.
Iterator<String>	getResponseHeaders(String name) Returns an iteration over all the string values of the specified header.
protected InputStream	getResponseInputStream() Returns the input stream to read the response from.
javax.jms.Message	getResponseMessage() Returns the response message, if any, for this connection.
URI	getUri() Returns the URI for this connection.
boolean	hasError() Indicates whether this connection has an error.
protected boolean	hasResponse() Indicates whether this connection has a response.
protected void	onClose() Template method invoked from AbstractWebServiceConnection.close().
protected void	onReceiveBeforeRead() Called before a message has been read from the TransportInputStream.
protected void	onSendAfterWrite(WebServiceMessage message) Called after the given message has been written to the TransportOutputStream.

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

createTransportInputStream, createTransportOutputStream

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

close, onReceiveAfterRead, onSendBeforeWrite, receive, send

Methods inherited from class java.lang.Object

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

Constructor Detail

JmsSenderConnection

protected JmsSenderConnection(javax.jms.ConnectionFactory connectionFactory,
                              javax.jms.Connection connection,
                              javax.jms.Session session,
                              javax.jms.Destination requestDestination,
                              javax.jms.Message requestMessage)
                       throws javax.jms.JMSException

Constructs a new JMS connection with the given parameters.

Throws:

javax.jms.JMSException

Method Detail

getRequestMessage

public javax.jms.Message getRequestMessage()

Returns the request message for this connection. Returns either a BytesMessage or a TextMessage.

getResponseMessage

public javax.jms.Message getResponseMessage()

Returns the response message, if any, for this connection. Returns either a BytesMessage or a TextMessage.

getUri

public URI getUri()
           throws URISyntaxException

Description copied from interface: WebServiceConnection

Returns the URI for this connection.

Throws:

URISyntaxException

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.

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.

Returns:

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

Throws:

IOException

See Also:

WebServiceConnection.hasError()

addRequestHeader

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

Description copied from interface: HeadersAwareSenderWebServiceConnection

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

Parameters:

name - the name of the header

value - the value of the header

Throws:

IOException

getRequestOutputStream

protected OutputStream getRequestOutputStream()
                                       throws IOException

Description copied from class: AbstractSenderConnection

Returns the output stream to write the request to.

Specified by:

getRequestOutputStream in class AbstractSenderConnection

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

onReceiveBeforeRead

protected void onReceiveBeforeRead()
                            throws IOException

Description copied from class: AbstractWebServiceConnection

Called before a message has been read from the TransportInputStream. Called from AbstractWebServiceConnection.receive(WebServiceMessageFactory).

Default implementation does nothing.

Overrides:

onReceiveBeforeRead in class AbstractWebServiceConnection

Throws:

IOException - when an I/O exception occurs

hasResponse

protected boolean hasResponse()
                       throws IOException

Description copied from class: AbstractSenderConnection

Indicates whether this connection has a response.

Specified by:

hasResponse in class AbstractSenderConnection

Throws:

IOException

getResponseHeaderNames

public Iterator<String> getResponseHeaderNames()
                                        throws IOException

Description copied from interface: HeadersAwareSenderWebServiceConnection

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

Throws:

IOException

getResponseHeaders

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

Description copied from interface: HeadersAwareSenderWebServiceConnection

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.

Throws:

IOException

getResponseInputStream

protected InputStream getResponseInputStream()
                                      throws IOException

Description copied from class: AbstractSenderConnection

Returns the input stream to read the response from.

Specified by:

getResponseInputStream in class AbstractSenderConnection

Throws:

IOException

onClose

protected void onClose()
                throws IOException

Description copied from class: AbstractSenderConnection

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

Overrides:

onClose in class AbstractSenderConnection

Throws:

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