public class JmsSenderConnection
extends org.springframework.ws.transport.AbstractSenderConnection
WebServiceConnection that is used for client-side JMS access. Exposes a BytesMessage request and response message.| Modifier | Constructor and Description |
|---|---|
protected |
JmsSenderConnection(ConnectionFactory connectionFactory,
Connection connection,
Session session,
Destination requestDestination,
Message requestMessage)
Constructs a new JMS connection with the given parameters.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addRequestHeader(String name,
String value) |
String |
getErrorMessage() |
Message |
getRequestMessage()
Returns the request message for this connection.
|
protected OutputStream |
getRequestOutputStream() |
Iterator<String> |
getResponseHeaderNames() |
Iterator<String> |
getResponseHeaders(String name) |
protected InputStream |
getResponseInputStream() |
Message |
getResponseMessage()
Returns the response message, if any, for this connection.
|
URI |
getUri() |
boolean |
hasError() |
protected boolean |
hasResponse() |
protected void |
onClose() |
protected void |
onReceiveBeforeRead() |
protected void |
onSendAfterWrite(org.springframework.ws.WebServiceMessage message) |
createTransportInputStream, createTransportOutputStreamprotected JmsSenderConnection(ConnectionFactory connectionFactory, Connection connection, Session session, Destination requestDestination, Message requestMessage) throws JMSException
JMSExceptionpublic Message getRequestMessage()
BytesMessage or a TextMessage.public Message getResponseMessage()
BytesMessage or a TextMessage.public URI getUri() throws URISyntaxException
URISyntaxExceptionpublic boolean hasError()
throws IOException
IOExceptionpublic String getErrorMessage() throws IOException
IOExceptionpublic void addRequestHeader(String name, String value) throws IOException
IOExceptionprotected OutputStream getRequestOutputStream() throws IOException
getRequestOutputStream in class org.springframework.ws.transport.AbstractSenderConnectionIOExceptionprotected void onSendAfterWrite(org.springframework.ws.WebServiceMessage message)
throws IOException
onSendAfterWrite in class org.springframework.ws.transport.AbstractWebServiceConnectionIOExceptionprotected void onReceiveBeforeRead()
throws IOException
onReceiveBeforeRead in class org.springframework.ws.transport.AbstractWebServiceConnectionIOExceptionprotected boolean hasResponse()
throws IOException
hasResponse in class org.springframework.ws.transport.AbstractSenderConnectionIOExceptionpublic Iterator<String> getResponseHeaderNames() throws IOException
IOExceptionpublic Iterator<String> getResponseHeaders(String name) throws IOException
IOExceptionprotected InputStream getResponseInputStream() throws IOException
getResponseInputStream in class org.springframework.ws.transport.AbstractSenderConnectionIOExceptionprotected void onClose()
throws IOException
onClose in class org.springframework.ws.transport.AbstractSenderConnectionIOException