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 Object
implements RequestTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HermesJmsRequestTransport.UnresolvedJMSEndpointException

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	addSoapAction
protected String	clientID
protected String	durableSubscriptionName
protected static List<RequestFilter>	filters
protected hermes.Hermes	hermes
static String	IS_JMS_MESSAGE_RECEIVED
static String	JMS_ERROR
static String	JMS_MESSAGE_SEND
static String	JMS_RECEIVE_TIMEOUT
static String	JMS_RESPONSE
protected JMSEndpoint	jmsEndpoint
protected String	messageSelector
protected String	password
protected boolean	sendAsBytesMessage
protected String	username

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

REQUEST_TRANSPORT, WSDL_REQUEST

Constructor Summary

Constructors

Constructor and Description
HermesJmsRequestTransport()

Method Summary

Modifier and Type	Method and Description
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(String sessionName, Request request)
protected long	getTimeout(SubmitContext submitContext, Request request)
protected void	init(SubmitContext submitContext, Request request)
void	insertRequestFilter(RequestFilter filter, RequestFilter refFilter)
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 String IS_JMS_MESSAGE_RECEIVED

See Also:

Constant Field Values

JMS_MESSAGE_SEND

public static final String JMS_MESSAGE_SEND

See Also:

Constant Field Values

JMS_RESPONSE

public static final String JMS_RESPONSE

See Also:

Constant Field Values

JMS_ERROR

public static final String JMS_ERROR

See Also:

Constant Field Values

JMS_RECEIVE_TIMEOUT

public static final String JMS_RECEIVE_TIMEOUT

See Also:

Constant Field Values

username

protected String username

password

protected String password

jmsEndpoint

protected JMSEndpoint jmsEndpoint

durableSubscriptionName

protected String durableSubscriptionName

clientID

protected String clientID

messageSelector

protected String messageSelector

sendAsBytesMessage

protected boolean sendAsBytesMessage

addSoapAction

protected boolean addSoapAction

hermes

protected hermes.Hermes hermes

filters

protected static List<RequestFilter> filters

Constructor Detail

HermesJmsRequestTransport

public HermesJmsRequestTransport()

Method Detail

sendRequest

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

Specified by:

sendRequest in interface RequestTransport

Throws:

Exception

init

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

Throws:

NamingException

execute

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

Throws:

Exception

getHermes

protected hermes.Hermes getHermes(String sessionName,
                                  Request request)
                           throws NamingException

Throws:

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,
                                                              NamingException

Throws:

javax.jms.JMSException

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

insertRequestFilter

public void insertRequestFilter(RequestFilter filter,
                                RequestFilter refFilter)

Specified by:

insertRequestFilter in interface RequestTransport