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

java.lang.Object
  extended by 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  java.lang.String clientID
           
protected  java.lang.String durableSubscriptionName
           
protected  java.util.List<RequestFilter> filters
           
protected  hermes.Hermes hermes
           
static java.lang.String JMS_ERROR
           
static java.lang.String JMS_MESSAGE_RECEIVE
           
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  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  JMSHeader createJMSHeader(SubmitContext submitContext, Request request, hermes.Hermes hermes, javax.jms.Message message)
           
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)
           
protected  javax.jms.Message messageSend(SubmitContext submitContext, Request request, javax.jms.Session session, hermes.Hermes hermes, javax.jms.Queue queueSend)
           
 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

JMS_MESSAGE_RECEIVE

public static final java.lang.String JMS_MESSAGE_RECEIVE
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

hermes

protected hermes.Hermes hermes

filters

protected java.util.List<RequestFilter> filters
Constructor Detail

HermesJmsRequestTransport

public HermesJmsRequestTransport()
Method Detail

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

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)

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)
                                 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)
                                    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)


Copyright © 2005-2010 eviware.com. All Rights Reserved.