com.metamatrix.server.connector.service
Interface ConnectorServiceInterface

All Superinterfaces:

ServiceInterface

All Known Implementing Classes:

ConnectorService

public interface ConnectorServiceInterface
extends ServiceInterface

Interface ConnectorServiceInterface.

Field Summary

static java.lang.String

SERVICE_NAME

Fields inherited from interface com.metamatrix.platform.service.api.ServiceInterface

WAIT_TO_DIE_TIME

Method Summary

void	cancelRequest(AtomicRequestID request)
void	closeRequest(AtomicRequestID request)
void	executeRequest(AtomicRequestMessage request, ResultsReceiver<AtomicResultsMessage> resultListener) Execute the given request on a Connector.
SourceCapabilities	getCapabilities(RequestID requestId, java.io.Serializable executionPayload, org.teiid.dqp.internal.process.DQPWorkContext message)
java.util.Collection<MMConnectionPool>	getConnectionPoolStats()
com.metamatrix.dqp.internal.datamgr.ConnectorID	getConnectorID() Get the ConnectorID of the connector we're servicing.
void	requestBatch(AtomicRequestID request)

Methods inherited from interface com.metamatrix.platform.service.api.ServiceInterface

checkState, die, dieNow, getCurrentState, getHostname, getID, getInitException, getProcessName, getProperties, getQueueStatistics, getQueueStatistics, getServiceData, getServiceType, getStartTime, getStateChangeTime, init, isAlive, setInitException, updateState

Field Detail

SERVICE_NAME

static final java.lang.String SERVICE_NAME

See Also:

Constant Field Values

Method Detail

getConnectorID

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

Get the ConnectorID of the connector we're servicing.

Returns:

The ConnectorID.

getCapabilities

SourceCapabilities getCapabilities(RequestID requestId,
                                   java.io.Serializable executionPayload,
                                   org.teiid.dqp.internal.process.DQPWorkContext message)
                                   throws ConnectorException

Throws:

ConnectorException

executeRequest

void executeRequest(AtomicRequestMessage request,
                    ResultsReceiver<AtomicResultsMessage> resultListener)
                    throws MetaMatrixComponentException

Execute the given request on a Connector.

Parameters:

request -

Throws:

MetaMatrixComponentException

cancelRequest

void cancelRequest(AtomicRequestID request)
                   throws MetaMatrixComponentException

Throws:

MetaMatrixComponentException

closeRequest

void closeRequest(AtomicRequestID request)
                  throws MetaMatrixComponentException

Throws:

MetaMatrixComponentException

requestBatch

void requestBatch(AtomicRequestID request)
                  throws MetaMatrixComponentException

Throws:

MetaMatrixComponentException

getConnectionPoolStats

java.util.Collection<MMConnectionPool> getConnectionPoolStats()