com.metamatrix.connector.xml.jms
Class JMSRequestExecutor

java.lang.Object
  com.metamatrix.connector.xml.jms.JMSRequestExecutor

All Implemented Interfaces:

AsynchronousDocumentProducer, DocumentProducer, javax.jms.MessageListener

public class JMSRequestExecutor
extends java.lang.Object
implements AsynchronousDocumentProducer, javax.jms.MessageListener

Constructor Summary

JMSRequestExecutor(JMSXMLConnectorState state, JMSExecution execution)

Method Summary

java.lang.String	getCacheKey(int i)
int	getDocumentCount()
java.io.Serializable	getRequestObject(int i)
Response	getXMLResponse(int invocationNumber)
boolean	hasResponse()
void	onMessage(javax.jms.Message message)
XMLDocument	recreateDocument(java.io.Serializable requestObject)

Methods inherited from class java.lang.Object

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

Constructor Detail

JMSRequestExecutor

public JMSRequestExecutor(JMSXMLConnectorState state,
                          JMSExecution execution)
                   throws ConnectorException

Throws:

ConnectorException

Method Detail

recreateDocument

public XMLDocument recreateDocument(java.io.Serializable requestObject)
                             throws ConnectorException

Throws:

ConnectorException

getRequestObject

public java.io.Serializable getRequestObject(int i)
                                      throws ConnectorException

Specified by:

getRequestObject in interface DocumentProducer

Throws:

ConnectorException

getDocumentCount

public int getDocumentCount()
                     throws ConnectorException

Specified by:

getDocumentCount in interface DocumentProducer

Throws:

ConnectorException

getCacheKey

public java.lang.String getCacheKey(int i)
                             throws ConnectorException

Specified by:

getCacheKey in interface DocumentProducer

Throws:

ConnectorException

getXMLResponse

public Response getXMLResponse(int invocationNumber)
                        throws ConnectorException

Specified by:

getXMLResponse in interface DocumentProducer

Throws:

ConnectorException

hasResponse

public boolean hasResponse()
                    throws ConnectorException

Specified by:

hasResponse in interface AsynchronousDocumentProducer

Throws:

ConnectorException

onMessage

public void onMessage(javax.jms.Message message)

Specified by:

onMessage in interface javax.jms.MessageListener