com.metamatrix.dqp.message
Class AtomicRequestMessage

java.lang.Object
  com.metamatrix.dqp.message.AtomicRequestMessage

All Implemented Interfaces:

java.io.Serializable

public class AtomicRequestMessage
extends java.lang.Object
implements java.io.Serializable

This class defines a request message for the Connector layer. This is uniquely identified by AtomicRequestID.

See Also:

Serialized Form

Constructor Summary

AtomicRequestMessage()

AtomicRequestMessage(RequestMessage requestMessage, org.teiid.dqp.internal.process.DQPWorkContext parent, int nodeId)

Method Summary

AtomicRequestID	getAtomicRequestID()
Command	getCommand()
java.lang.String	getConnectorBindingID()
com.metamatrix.dqp.internal.datamgr.ConnectorID	getConnectorID()
java.io.Serializable	getExecutionPayload()
int	getFetchSize()
java.lang.String	getModelName()
java.util.Date	getProcessingTimestamp() Get time that the request was assigned a unique ID by the server.
RequestID	getRequestID()
java.util.Date	getSubmittedTimestamp() Get time that the time when the command was created by the client.
TransactionContext	getTransactionContext()
org.teiid.dqp.internal.process.DQPWorkContext	getWorkContext()
boolean	isTransactional()
void	markProcessingStart() Start the clock on processing times - this should be called when the query hits the QueryService or SubscriptionService.
void	markSubmissionStart() Start the clock on submission start - this should be called when the request is originally created.
void	setCommand(Command command)
void	setConnectorBindingID(java.lang.String string)
void	setConnectorID(com.metamatrix.dqp.internal.datamgr.ConnectorID connectorID)
void	setExecutionPayload(java.io.Serializable executionPayload)
void	setFetchSize(int fetchSize)
void	setModelName(java.lang.String modelName)
void	setPartialResults(boolean partial)
void	setProcessingTimestamp(java.util.Date processingTimestamp) Set time that the request is submitted on the server.
void	setRequestID(RequestID requestID)
void	setSubmittedTimestamp(java.util.Date submittedTimestamp) Set time that the time when the command was created by the client.
void	setTransactionContext(TransactionContext context)
void	setUseResultSetCache(boolean useResultSetCacse)
void	setWorkContext(org.teiid.dqp.internal.process.DQPWorkContext workContext)
boolean	supportsPartialResults()
java.lang.String	toString()
boolean	useResultSetCache()

Methods inherited from class java.lang.Object

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

Constructor Detail

AtomicRequestMessage

public AtomicRequestMessage()

AtomicRequestMessage

public AtomicRequestMessage(RequestMessage requestMessage,
                            org.teiid.dqp.internal.process.DQPWorkContext parent,
                            int nodeId)

Method Detail

getAtomicRequestID

public AtomicRequestID getAtomicRequestID()

getConnectorBindingID

public java.lang.String getConnectorBindingID()

getConnectorID

public com.metamatrix.dqp.internal.datamgr.ConnectorID getConnectorID()

setConnectorID

public void setConnectorID(com.metamatrix.dqp.internal.datamgr.ConnectorID connectorID)

setConnectorBindingID

public void setConnectorBindingID(java.lang.String string)

getModelName

public java.lang.String getModelName()

setModelName

public void setModelName(java.lang.String modelName)

getTransactionContext

public TransactionContext getTransactionContext()

setTransactionContext

public void setTransactionContext(TransactionContext context)

isTransactional

public boolean isTransactional()

getCommand

public Command getCommand()

setCommand

public void setCommand(Command command)

getFetchSize

public int getFetchSize()

setFetchSize

public void setFetchSize(int fetchSize)

getSubmittedTimestamp

public java.util.Date getSubmittedTimestamp()

Get time that the time when the command was created by the client.

Returns:

timestamp in millis

setSubmittedTimestamp

public void setSubmittedTimestamp(java.util.Date submittedTimestamp)

Set time that the time when the command was created by the client. NOTE: By default, this gets set to the current time by the constructor.

Parameters:

submittedTimestamp - Time submitted to server.

markSubmissionStart

public void markSubmissionStart()

Start the clock on submission start - this should be called when the request is originally created.

getProcessingTimestamp

public java.util.Date getProcessingTimestamp()

Get time that the request was assigned a unique ID by the server.

Returns:

timestamp in millis

setProcessingTimestamp

public void setProcessingTimestamp(java.util.Date processingTimestamp)

Set time that the request is submitted on the server.

Parameters:

processingTimestamp - Time submitted to server.

markProcessingStart

public void markProcessingStart()

Start the clock on processing times - this should be called when the query hits the QueryService or SubscriptionService.

useResultSetCache

public boolean useResultSetCache()

setUseResultSetCache

public void setUseResultSetCache(boolean useResultSetCacse)

supportsPartialResults

public boolean supportsPartialResults()

setPartialResults

public void setPartialResults(boolean partial)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

setExecutionPayload

public void setExecutionPayload(java.io.Serializable executionPayload)

getExecutionPayload

public java.io.Serializable getExecutionPayload()

setRequestID

public void setRequestID(RequestID requestID)

getRequestID

public RequestID getRequestID()

setWorkContext

public void setWorkContext(org.teiid.dqp.internal.process.DQPWorkContext workContext)

getWorkContext

public org.teiid.dqp.internal.process.DQPWorkContext getWorkContext()