com.metamatrix.dqp.embedded.admin
Class DQPRuntimeStateAdminImpl

java.lang.Object
  com.metamatrix.dqp.embedded.admin.DQPRuntimeStateAdminImpl

All Implemented Interfaces:

RuntimeStateAdmin

public class DQPRuntimeStateAdminImpl
extends java.lang.Object
implements RuntimeStateAdmin

Since:

4.3

Constructor Summary

DQPRuntimeStateAdminImpl(EmbeddedConnectionFactoryImpl manager)

Method Summary

protected AdminException	accumulateProcessingException(AdminException parent, java.lang.Exception e)
protected AdminException	accumulateSystemException(AdminException parent, java.lang.Exception e)
void	cancelRequest(java.lang.String identifier) Cancel Request
void	cancelSourceRequest(java.lang.String identifier) Cancel Source Request
void	changeVDBStatus(java.lang.String name, java.lang.String version, int status) Change the status of a Deployed VDB
void	clearCache(java.lang.String identifier) Clear the cache or caches specified by the cacheIdentifier.
protected java.util.Collection	convertPropertyDefinitions(ComponentType ctype, java.util.Properties properties) Convert a ComponentType and a set of properties into a Collection of com.metamatrix.admin.api.objects.PropertyDefinition objects
protected java.util.Collection	convertPropertyDefinitions(java.util.Properties properties) Convert a set of properties into a Collection of com.metamatrix.admin.api.objects.PropertyDefinition objects
protected java.lang.Object	convertToAdminObjects(java.lang.Object src)
protected java.lang.Object	convertToAdminObjects(java.lang.Object src, java.lang.Object parent)
EmbeddedConnectionFactoryImpl	getManager()
protected java.lang.String	prettyPrintBindingNames(java.util.List bindings)
void	restart() Restart System
void	shutdown(int millisToWait) Stop the MM Query.
void	startConnectorBinding(java.lang.String identifier) Start Connector Binding
void	stopConnectorBinding(java.lang.String identifier, boolean stopNow) Stop Connector Binding
void	terminateSession(java.lang.String identifier) Terminate the Session
void	terminateTransaction(java.lang.String transactionId, java.lang.String sessionId) Mark the given transaction as rollback only.
void	terminateTransaction(javax.transaction.xa.Xid transactionId) Mark the given global transaction as rollback only.
protected SessionToken	validateSession()

Methods inherited from class java.lang.Object

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

Constructor Detail

DQPRuntimeStateAdminImpl

public DQPRuntimeStateAdminImpl(EmbeddedConnectionFactoryImpl manager)

Method Detail

shutdown

public void shutdown(int millisToWait)
              throws AdminException

Description copied from interface: RuntimeStateAdmin

Stop the MM Query. If millisToWait is >0, then close to incoming queries, wait the time period for work to stop, then stop the MM Query. Otherwise, stop immediately, aborting all running queries.

Specified by:

shutdown in interface RuntimeStateAdmin

Parameters:

millisToWait - Milliseconds to wait (if >0) or <=0 for no wait before stopping

Throws:

AdminException

Since:

4.3

See Also:

com.metamatrix.admin.api.embedded.EmbeddedRuntimeStateAdmin#stop(int)

restart

public void restart()
             throws AdminException

Description copied from interface: RuntimeStateAdmin

Restart System

Specified by:

restart in interface RuntimeStateAdmin

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

com.metamatrix.admin.api.embedded.EmbeddedRuntimeStateAdmin#restart()

startConnectorBinding

public void startConnectorBinding(java.lang.String identifier)
                           throws AdminException

Description copied from interface: RuntimeStateAdmin

Start Connector Binding

Specified by:

startConnectorBinding in interface RuntimeStateAdmin

Parameters:

identifier - identifier for ConnectorBinding

• "*" - for all connector bindings in the system
• "name*" - for all connector bindings that begin with given name
• "name" - for single connector binding by the given name

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

RuntimeStateAdmin.startConnectorBinding(java.lang.String)

stopConnectorBinding

public void stopConnectorBinding(java.lang.String identifier,
                                 boolean stopNow)
                          throws AdminException

Description copied from interface: RuntimeStateAdmin

Stop Connector Binding

Specified by:

stopConnectorBinding in interface RuntimeStateAdmin

Parameters:

identifier - identifier for ConnectorBinding

• "*" - for all connector bindings in the system
• "name*" - for all connector bindings that begin with given name
• "name" - for single connector binding by the given name

stopNow - If true, stop the process forcefully. If false, wait until any pending work is done.

Throws:

AdminException - - if there's a system error.

Since:

4.3

See Also:

RuntimeStateAdmin.stopConnectorBinding(java.lang.String, boolean)

clearCache

public void clearCache(java.lang.String identifier)
                throws AdminException

Description copied from interface: RuntimeStateAdmin

Clear the cache or caches specified by the cacheIdentifier.

Specified by:

clearCache in interface RuntimeStateAdmin

Parameters:

identifier - Cache name identifier Cache. No wild cards currently supported, must be explicit

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

RuntimeStateAdmin.clearCache(java.lang.String)

terminateSession

public void terminateSession(java.lang.String identifier)
                      throws AdminException

Description copied from interface: RuntimeStateAdmin

Terminate the Session

Specified by:

terminateSession in interface RuntimeStateAdmin

Parameters:

identifier - Session Identifier Session. No wild cards currently supported, must be explicit

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

RuntimeStateAdmin.terminateSession(java.lang.String)

cancelRequest

public void cancelRequest(java.lang.String identifier)
                   throws AdminException

Description copied from interface: RuntimeStateAdmin

Cancel Request

Specified by:

cancelRequest in interface RuntimeStateAdmin

Parameters:

identifier - The request identifier defined by Request No wild cards currently supported, must be explicit

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

RuntimeStateAdmin.cancelRequest(java.lang.String)

cancelSourceRequest

public void cancelSourceRequest(java.lang.String identifier)
                         throws AdminException

Description copied from interface: RuntimeStateAdmin

Cancel Source Request

Specified by:

cancelSourceRequest in interface RuntimeStateAdmin

Parameters:

identifier - The request identifier defined by Request No wild cards currently supported, must be explicit

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

RuntimeStateAdmin.cancelSourceRequest(java.lang.String)

changeVDBStatus

public void changeVDBStatus(java.lang.String name,
                            java.lang.String version,
                            int status)
                     throws AdminException

Description copied from interface: RuntimeStateAdmin

Change the status of a Deployed VDB

Specified by:

changeVDBStatus in interface RuntimeStateAdmin

Parameters:

name - Name of the Virtual Database

version - Version of the Virtual Database

status - Active, InActive, Delete

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

RuntimeStateAdmin.changeVDBStatus(java.lang.String, java.lang.String, int)

terminateTransaction

public void terminateTransaction(java.lang.String transactionId,
                                 java.lang.String sessionId)
                          throws AdminException

Description copied from interface: RuntimeStateAdmin

Mark the given transaction as rollback only.

Specified by:

terminateTransaction in interface RuntimeStateAdmin

Throws:

AdminException

terminateTransaction

public void terminateTransaction(javax.transaction.xa.Xid transactionId)
                          throws AdminException

Description copied from interface: RuntimeStateAdmin

Mark the given global transaction as rollback only.

Specified by:

terminateTransaction in interface RuntimeStateAdmin

Throws:

AdminException

accumulateSystemException

protected AdminException accumulateSystemException(AdminException parent,
                                                   java.lang.Exception e)

accumulateProcessingException

protected AdminException accumulateProcessingException(AdminException parent,
                                                       java.lang.Exception e)

prettyPrintBindingNames

protected java.lang.String prettyPrintBindingNames(java.util.List bindings)

getManager

public EmbeddedConnectionFactoryImpl getManager()

Returns:

Returns the manager.

Since:

4.3

convertToAdminObjects

protected java.lang.Object convertToAdminObjects(java.lang.Object src)

convertToAdminObjects

protected java.lang.Object convertToAdminObjects(java.lang.Object src,
                                                 java.lang.Object parent)

convertPropertyDefinitions

protected java.util.Collection convertPropertyDefinitions(ComponentType ctype,
                                                          java.util.Properties properties)

Convert a ComponentType and a set of properties into a Collection of com.metamatrix.admin.api.objects.PropertyDefinition objects

Parameters:

ctype -

properties -

Returns:

Since:

4.3

convertPropertyDefinitions

protected java.util.Collection convertPropertyDefinitions(java.util.Properties properties)

Convert a set of properties into a Collection of com.metamatrix.admin.api.objects.PropertyDefinition objects

Parameters:

ctype -

properties -

Returns:

Since:

4.3

validateSession

protected SessionToken validateSession()