com.eviware.soapui.impl.wsdl.submit.transports.jms
Class HermesJmsRequestTransport

java.lang.Object
  com.eviware.soapui.impl.wsdl.submit.transports.jms.HermesJmsRequestTransport

All Implemented Interfaces:

RequestTransport

Direct Known Subclasses:

HermesJmsRequestPublishReceiveTransport, HermesJmsRequestPublishSubscribeTransport, HermesJmsRequestPublishTransport, HermesJmsRequestReceiveTransport, HermesJmsRequestSendReceiveTransport, HermesJmsRequestSendSubscribeTransport, HermesJmsRequestSendTransport, HermesJmsRequestSubscribeTransport

public class HermesJmsRequestTransport
extends java.lang.Object
implements RequestTransport

Nested Class Summary

static class

HermesJmsRequestTransport.UnresolvedJMSEndpointException

Field Summary

protected boolean	addSoapAction
protected java.lang.String	clientID
protected java.lang.String	durableSubscriptionName
protected static java.util.List<RequestFilter>	filters
protected hermes.Hermes	hermes
static java.lang.String	IS_JMS_MESSAGE_RECEIVED
static java.lang.String	JMS_ERROR
static java.lang.String	JMS_MESSAGE_SEND
static java.lang.String	JMS_RECEIVE_TIMEOUT
static java.lang.String	JMS_RESPONSE
protected JMSEndpoint	jmsEndpoint
protected java.lang.String	messageSelector
protected java.lang.String	password
protected boolean	sendAsBytesMessage
protected java.lang.String	username

Fields inherited from interface com.eviware.soapui.impl.wsdl.submit.RequestTransport

REQUEST_TRANSPORT, WSDL_REQUEST

Constructor Summary

HermesJmsRequestTransport()

Method Summary

void	abortRequest(SubmitContext submitContext)
void	addRequestFilter(RequestFilter filter)
protected void	closeSessionAndConnection(javax.jms.Connection connection, javax.jms.Session session)
protected javax.jms.TopicSubscriber	createDurableSubscription(SubmitContext submitContext, javax.jms.Session topicSession, JMSConnectionHolder jmsConnectionHolder)
protected JMSHeader	createJMSHeader(SubmitContext submitContext, Request request, hermes.Hermes hermes, javax.jms.Message message, javax.jms.Destination replyToDestination)
protected Response	errorResponse(SubmitContext submitContext, Request request, long timeStarted, javax.jms.JMSException jmse)
protected Response	execute(SubmitContext submitContext, Request request, long timeStarted)
protected hermes.Hermes	getHermes(java.lang.String sessionName, Request request)
protected long	getTimeout(SubmitContext submitContext, Request request)
protected void	init(SubmitContext submitContext, Request request)
protected Response	makeEmptyResponse(SubmitContext submitContext, Request request, long timeStarted, javax.jms.Message messageSend)
protected Response	makeResponse(SubmitContext submitContext, Request request, long timeStarted, javax.jms.Message messageSend, javax.jms.MessageConsumer messageConsumer)
protected javax.jms.Message	messagePublish(SubmitContext submitContext, Request request, javax.jms.Session topicSession, hermes.Hermes hermes, javax.jms.Topic topicPublish, javax.jms.Destination replyToDestination)
protected javax.jms.Message	messageSend(SubmitContext submitContext, Request request, javax.jms.Session session, hermes.Hermes hermes, javax.jms.Queue queueSend, javax.jms.Destination replyToDestination)
void	removeRequestFilter(RequestFilter filter)
Response	sendRequest(SubmitContext submitContext, Request request)

Methods inherited from class java.lang.Object

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

Field Detail

IS_JMS_MESSAGE_RECEIVED

public static final java.lang.String IS_JMS_MESSAGE_RECEIVED

See Also:

Constant Field Values

JMS_MESSAGE_SEND

public static final java.lang.String JMS_MESSAGE_SEND

See Also:

Constant Field Values

JMS_RESPONSE

public static final java.lang.String JMS_RESPONSE

See Also:

Constant Field Values

JMS_ERROR

public static final java.lang.String JMS_ERROR

See Also:

Constant Field Values

JMS_RECEIVE_TIMEOUT

public static final java.lang.String JMS_RECEIVE_TIMEOUT

See Also:

Constant Field Values

username

protected java.lang.String username

password

protected java.lang.String password

jmsEndpoint

protected JMSEndpoint jmsEndpoint

durableSubscriptionName

protected java.lang.String durableSubscriptionName

clientID

protected java.lang.String clientID

messageSelector

protected java.lang.String messageSelector

sendAsBytesMessage

protected boolean sendAsBytesMessage

addSoapAction

protected boolean addSoapAction

hermes

protected hermes.Hermes hermes

filters

protected static java.util.List<RequestFilter> filters

Constructor Detail

HermesJmsRequestTransport

public HermesJmsRequestTransport()

Method Detail

sendRequest

public Response sendRequest(SubmitContext submitContext,
                            Request request)
                     throws java.lang.Exception

Specified by:

sendRequest in interface RequestTransport

Throws:

java.lang.Exception

init

protected void init(SubmitContext submitContext,
                    Request request)
             throws javax.naming.NamingException

Throws:

javax.naming.NamingException

execute

protected Response execute(SubmitContext submitContext,
                           Request request,
                           long timeStarted)
                    throws java.lang.Exception

Throws:

java.lang.Exception

getHermes

protected hermes.Hermes getHermes(java.lang.String sessionName,
                                  Request request)
                           throws javax.naming.NamingException

Throws:

javax.naming.NamingException

getTimeout

protected long getTimeout(SubmitContext submitContext,
                          Request request)

createJMSHeader

protected JMSHeader createJMSHeader(SubmitContext submitContext,
                                    Request request,
                                    hermes.Hermes hermes,
                                    javax.jms.Message message,
                                    javax.jms.Destination replyToDestination)

closeSessionAndConnection

protected void closeSessionAndConnection(javax.jms.Connection connection,
                                         javax.jms.Session session)
                                  throws javax.jms.JMSException

Throws:

javax.jms.JMSException

errorResponse

protected Response errorResponse(SubmitContext submitContext,
                                 Request request,
                                 long timeStarted,
                                 javax.jms.JMSException jmse)

messageSend

protected javax.jms.Message messageSend(SubmitContext submitContext,
                                        Request request,
                                        javax.jms.Session session,
                                        hermes.Hermes hermes,
                                        javax.jms.Queue queueSend,
                                        javax.jms.Destination replyToDestination)
                                 throws javax.jms.JMSException

Throws:

javax.jms.JMSException

messagePublish

protected javax.jms.Message messagePublish(SubmitContext submitContext,
                                           Request request,
                                           javax.jms.Session topicSession,
                                           hermes.Hermes hermes,
                                           javax.jms.Topic topicPublish,
                                           javax.jms.Destination replyToDestination)
                                    throws javax.jms.JMSException

Throws:

javax.jms.JMSException

makeResponse

protected Response makeResponse(SubmitContext submitContext,
                                Request request,
                                long timeStarted,
                                javax.jms.Message messageSend,
                                javax.jms.MessageConsumer messageConsumer)
                         throws javax.jms.JMSException

Throws:

javax.jms.JMSException

makeEmptyResponse

protected Response makeEmptyResponse(SubmitContext submitContext,
                                     Request request,
                                     long timeStarted,
                                     javax.jms.Message messageSend)

createDurableSubscription

protected javax.jms.TopicSubscriber createDurableSubscription(SubmitContext submitContext,
                                                              javax.jms.Session topicSession,
                                                              JMSConnectionHolder jmsConnectionHolder)
                                                       throws javax.jms.JMSException,
                                                              javax.naming.NamingException

Throws:

javax.jms.JMSException

javax.naming.NamingException

abortRequest

public void abortRequest(SubmitContext submitContext)

Specified by:

abortRequest in interface RequestTransport

addRequestFilter

public void addRequestFilter(RequestFilter filter)

Specified by:

addRequestFilter in interface RequestTransport

removeRequestFilter

public void removeRequestFilter(RequestFilter filter)

Specified by:

removeRequestFilter in interface RequestTransport