com.metamatrix.dqp.embedded.admin
Class DQPRuntimeStateAdminImpl

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

All Implemented Interfaces:

CoreRuntimeStateAdmin, EmbeddedRuntimeStateAdmin

public class DQPRuntimeStateAdminImpl
extends java.lang.Object
implements EmbeddedRuntimeStateAdmin

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)
protected java.util.Collection	getAdminObjects(java.lang.String identifier, java.lang.String className) Get admin objects of the specified className that match the specified identifier.
EmbeddedConnectionFactoryImpl	getManager()
SystemObject	getSystem() Get the system state.
protected java.lang.String	prettyPrintBindingNames(java.util.List bindings)
void	restart() Restart MM Query
void	setLogListener(EmbeddedLogger listener) Set the log listener to install into MM Query.
void	startConnectorBinding(java.lang.String identifier) Start Connector Binding
void	stop(int millisToWait) Stop the MM Query.
void	stopConnectorBinding(java.lang.String identifier, boolean stopNow) Stop Connector Binding
void	terminateSession(java.lang.String identifier) Terminate the Session

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

stop

public void stop(int millisToWait)
          throws AdminException

Description copied from interface: EmbeddedRuntimeStateAdmin

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:

stop in interface EmbeddedRuntimeStateAdmin

Parameters:

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

Throws:

AdminException

Since:

4.3

See Also:

EmbeddedRuntimeStateAdmin.stop(int)

restart

public void restart()
             throws AdminException

Description copied from interface: EmbeddedRuntimeStateAdmin

Restart MM Query

Specified by:

restart in interface EmbeddedRuntimeStateAdmin

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

EmbeddedRuntimeStateAdmin.restart()

startConnectorBinding

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

Description copied from interface: CoreRuntimeStateAdmin

Start Connector Binding

Specified by:

startConnectorBinding in interface CoreRuntimeStateAdmin

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:

CoreRuntimeStateAdmin.startConnectorBinding(java.lang.String)

stopConnectorBinding

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

Description copied from interface: CoreRuntimeStateAdmin

Stop Connector Binding

Specified by:

stopConnectorBinding in interface CoreRuntimeStateAdmin

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:

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

clearCache

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

Description copied from interface: CoreRuntimeStateAdmin

Clear the cache or caches specified by the cacheIdentifier.

Specified by:

clearCache in interface CoreRuntimeStateAdmin

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:

CoreRuntimeStateAdmin.clearCache(java.lang.String)

terminateSession

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

Description copied from interface: CoreRuntimeStateAdmin

Terminate the Session

Specified by:

terminateSession in interface CoreRuntimeStateAdmin

Parameters:

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

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

CoreRuntimeStateAdmin.terminateSession(java.lang.String)

cancelRequest

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

Description copied from interface: CoreRuntimeStateAdmin

Cancel Request

Specified by:

cancelRequest in interface CoreRuntimeStateAdmin

Parameters:

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

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

CoreRuntimeStateAdmin.cancelRequest(java.lang.String)

cancelSourceRequest

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

Description copied from interface: CoreRuntimeStateAdmin

Cancel Source Request

Specified by:

cancelSourceRequest in interface CoreRuntimeStateAdmin

Parameters:

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

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

CoreRuntimeStateAdmin.cancelSourceRequest(java.lang.String)

changeVDBStatus

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

Description copied from interface: CoreRuntimeStateAdmin

Change the status of a Deployed VDB

Specified by:

changeVDBStatus in interface CoreRuntimeStateAdmin

Parameters:

name - Name of the Virtial Database

version - Version of the Virtial Database

status - Active, InActive, Delete

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

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

setLogListener

public void setLogListener(EmbeddedLogger listener)
                    throws AdminException

Description copied from interface: EmbeddedRuntimeStateAdmin

Set the log listener to install into MM Query. This log listener will receive all log messages written by the MM Query at it's current log level and log contexts.

Specified by:

setLogListener in interface EmbeddedRuntimeStateAdmin

Parameters:

listener - The listener component

Throws:

AdminException - if there's a system error.

Since:

4.3

See Also:

com.metamatrix.admin.api.embedded.EmbeddedRuntimeStateAdmin#setLogListener(java.lang.Object)

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)

getSystem

public SystemObject getSystem()

Get the system state.

Returns:

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

getAdminObjects

protected java.util.Collection getAdminObjects(java.lang.String identifier,
                                               java.lang.String className)
                                        throws AdminException

Get admin objects of the specified className that match the specified identifier.

Parameters:

identifier -

className -

Returns:

Throws:

AdminException

Since:

4.3