Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

com.metamatrix.dqp.embedded.admin
Class DQPMonitoringAdminImpl

java.lang.Object
  extended by com.metamatrix.dqp.embedded.admin.DQPMonitoringAdminImpl
All Implemented Interfaces:
MonitoringAdmin
public class DQPMonitoringAdminImpl
extends java.lang.Object
implements MonitoringAdmin

DQP implementation of the Monitoring API

Since:
4.3

Constructor Summary
DQPMonitoringAdminImpl(EmbeddedConnectionFactoryImpl manager)
           
 
Method Summary
protected  AdminException accumulateProcessingException(AdminException parent, java.lang.Exception e)
           
protected  AdminException accumulateSystemException(AdminException parent, java.lang.Exception e)
           
protected  void changeVDBStatus(java.lang.String name, java.lang.String version, int status)
           
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)
           
 java.util.Collection<Cache> getCaches(java.lang.String identifier)
          Get the Caches that correspond to the specified identifier pattern
 java.util.Collection<? extends ConnectionPool> getConnectionPoolStats(java.lang.String identifier)
          Get the Connection Pool Stats that correspond to the specified identifier pattern.
 java.util.Collection<ConnectorBinding> getConnectorBindings(java.lang.String identifier)
          Get list of available connector bindings
 java.util.Collection<ConnectorBinding> getConnectorBindingsInVDB(java.lang.String vdbName, java.lang.String vdbVersion)
          Get all the Connector Bindings for the given VDB identifier pattern
 java.util.Collection<PropertyDefinition> getConnectorTypePropertyDefinitions(java.lang.String typeName)
          Get all of the available Configuration Properties for the specified AdminObject, and details about them.
 java.util.Collection<ConnectorType> getConnectorTypes(java.lang.String identifier)
          Get list of available connector types
 java.util.Collection<ExtensionModule> getExtensionModules(java.lang.String identifier)
          Get the Extension Modules that correspond to the specified identifier pattern
 EmbeddedConnectionFactoryImpl getManager()
           
 java.util.Collection<ProcessObject> getProcesses(java.lang.String processIdentifier)
          Get the processes that correspond to the specified identifier pattern.
 java.util.Collection<QueueWorkerPool> getQueueWorkerPools(java.lang.String identifier)
          Get the Queue Worker Pools that correspond to the specified identifier pattern.
 java.util.Collection<Request> getRequests(java.lang.String identifier)
          Get the Requests that correspond to the specified identifier pattern
 java.util.Collection<Session> getSessions(java.lang.String identifier)
          Get the Sessions that correspond to the specified identifier pattern
 java.util.Collection<Request> getSourceRequests(java.lang.String identifier)
          Get the Source Request that correspond to the specified identifier pattern
 java.util.Collection<Transaction> getTransactions()
          Get all transaction matching the identifier.
 java.util.Collection<VDB> getVDBs(java.lang.String identifier)
          Get the VDBs that correspond to the specified identifier pattern.
protected  java.lang.String prettyPrintBindingNames(java.util.List bindings)
           
protected  SessionToken validateSession()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DQPMonitoringAdminImpl

public DQPMonitoringAdminImpl(EmbeddedConnectionFactoryImpl manager)
Method Detail

getConnectorTypes

public java.util.Collection<ConnectorType> getConnectorTypes(java.lang.String identifier)
                                                      throws AdminException
Get list of available connector types

Specified by:
getConnectorTypes in interface MonitoringAdmin
Parameters:
identifier - the unique identifier for for a ConnectorType
  • "*" - for all connector types in the system
  • "name*" - for all the connector types that begin with given name
  • "name" - for the single connector type identified by name
Returns:
Collection of ConnectorType
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
MonitoringAdmin.getConnectorTypes(java.lang.String)

getVDBs

public java.util.Collection<VDB> getVDBs(java.lang.String identifier)
                                  throws AdminException
Description copied from interface: MonitoringAdmin
Get the VDBs that correspond to the specified identifier pattern.

Specified by:
getVDBs in interface MonitoringAdmin
Parameters:
identifier - the unique identifier for for a VDB in the system
  • "*" - for all VDBs in the system
  • "name" or "name*" - for all the VDBs that begin with given name
  • "name<AdminObject.DELIMITER_CHAR>version" - for single VDB
Returns:
Collection of VDBs. There could be multiple VDBs with the same name in the Collection but they will differ by VDB version.
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
MonitoringAdmin.getVDBs(java.lang.String)

getConnectorBindings

public java.util.Collection<ConnectorBinding> getConnectorBindings(java.lang.String identifier)
                                                            throws AdminException
Get list of available connector bindings

Specified by:
getConnectorBindings in interface MonitoringAdmin
Parameters:
identifier - the unique identifier pattern of 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
Returns:
Collection of ConnectorBinding
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
MonitoringAdmin.getConnectorBindings(java.lang.String)

getConnectorBindingsInVDB

public java.util.Collection<ConnectorBinding> getConnectorBindingsInVDB(java.lang.String vdbName,
                                                                        java.lang.String vdbVersion)
                                                                 throws AdminException
Description copied from interface: MonitoringAdmin
Get all the Connector Bindings for the given VDB identifier pattern

Specified by:
getConnectorBindingsInVDB in interface MonitoringAdmin
Parameters:
vdbName - - Name of the VDB
vdbVersion - - version of the VDB
Returns:
Collection of ConnectorBinding
Throws:
AdminException - if there's a system error.

getExtensionModules

public java.util.Collection<ExtensionModule> getExtensionModules(java.lang.String identifier)
                                                          throws AdminException
Description copied from interface: MonitoringAdmin
Get the Extension Modules that correspond to the specified identifier pattern

Specified by:
getExtensionModules in interface MonitoringAdmin
Parameters:
identifier - - the unique identifier for ExtensionModule
  • "*" - for all extension modules in the system
  • "name*" - for all the extension modules in that begin with given name
  • "name" - for a single extension module identified by given name
Returns:
Collection of ExtensionModule
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
MonitoringAdmin.getExtensionModules(java.lang.String)

getQueueWorkerPools

public java.util.Collection<QueueWorkerPool> getQueueWorkerPools(java.lang.String identifier)
                                                          throws AdminException
Description copied from interface: MonitoringAdmin
Get the Queue Worker Pools that correspond to the specified identifier pattern.

Specified by:
getQueueWorkerPools in interface MonitoringAdmin
Parameters:
identifier - - an identfier for the queues QueueWorkerPool
  • "*" - for all Queue workers in the system
  • "name*" - for all the Queue workers in that begin with given name
  • "name" - for a single queue in the system
for example, In MM Query - "dqp" will return the Stats for MM Query Worker Pool. Also any Connector Binding name will return the stats for that connector binding.
Returns:
Collection of QueueWorkerPool
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
MonitoringAdmin.getQueueWorkerPools(java.lang.String)

getCaches

public java.util.Collection<Cache> getCaches(java.lang.String identifier)
                                      throws AdminException
Description copied from interface: MonitoringAdmin
Get the Caches that correspond to the specified identifier pattern

Specified by:
getCaches in interface MonitoringAdmin
Parameters:
identifier - - an identifier for the cache in Cache
  • "*" - for all different caches in the system
  • "name*" - for all the caches that begin with given name
  • "name" - for a single cache in the system
Returns:
Collection of Cache
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
MonitoringAdmin.getCaches(java.lang.String)

getSessions

public java.util.Collection<Session> getSessions(java.lang.String identifier)
                                          throws AdminException
Description copied from interface: MonitoringAdmin
Get the Sessions that correspond to the specified identifier pattern

Specified by:
getSessions in interface MonitoringAdmin
Parameters:
identifier - - an unique identifier for Session
  • "*" - for all current sessions of the system
  • "number*" - for all the sessions that begin with given number
  • "number" - for a single current session in the system
Returns:
Collection of Session
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
MonitoringAdmin.getSessions(java.lang.String)

getRequests

public java.util.Collection<Request> getRequests(java.lang.String identifier)
                                          throws AdminException
Description copied from interface: MonitoringAdmin
Get the Requests that correspond to the specified identifier pattern

Specified by:
getRequests in interface MonitoringAdmin
Parameters:
identifier - - An Identifier for Request
  • "*" - for all current in process requests of the system
  • "number* or number<AdminObject.DELIMITER_CHAR>*" - for all the sessions that begin with given number, or all the requests for particular session etc.
  • "number<AdminObject.DELIMITER_CHAR>number" - for a single request in the system
Returns:
Collection of Request
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
MonitoringAdmin.getRequests(java.lang.String)

getSourceRequests

public java.util.Collection<Request> getSourceRequests(java.lang.String identifier)
                                                throws AdminException
Description copied from interface: MonitoringAdmin
Get the Source Request that correspond to the specified identifier pattern

Specified by:
getSourceRequests in interface MonitoringAdmin
Parameters:
identifier - An Identifier for Request
Returns:
Collection of Request
Throws:
AdminException - if there's a system error.
Since:
4.3
See Also:
MonitoringAdmin.getSourceRequests(java.lang.String)

getConnectorTypePropertyDefinitions

public java.util.Collection<PropertyDefinition> getConnectorTypePropertyDefinitions(java.lang.String typeName)
                                                                             throws AdminException
Description copied from interface: MonitoringAdmin
Get all of the available Configuration Properties for the specified AdminObject, and details about them.

Specified by:
getConnectorTypePropertyDefinitions in interface MonitoringAdmin
Returns:
Throws:
AdminException
Since:
4.3
See Also:
org.teiid.adminapi.MonitoringAdmin#getPropertyDefinitions(java.lang.String, java.lang.String)

getTransactions

public java.util.Collection<Transaction> getTransactions()
                                                  throws AdminException
Description copied from interface: MonitoringAdmin
Get all transaction matching the identifier.

Specified by:
getTransactions in interface MonitoringAdmin
Returns:
Throws:
AdminException

getConnectionPoolStats

public java.util.Collection<? extends ConnectionPool> getConnectionPoolStats(java.lang.String identifier)
                                                                      throws AdminException
Description copied from interface: MonitoringAdmin
Get the Connection Pool Stats that correspond to the specified identifier pattern. If the ConnectionPool represents an XA connection, there will be 2 ConnectionPools.

Specified by:
getConnectionPoolStats in interface MonitoringAdmin
Parameters:
identifier - - an identfier that corresponds to the ConnectorBinding that is running in a process ConnectionPool
  • "*" - for all Connection Pools in the system
  • "name*" - for all the Connection Pools that begin with given name
  • "name" - for a single Connection Pool in the system
Returns:
Collection of ConnectionPool
Throws:
AdminException - if there's a system error.

getProcesses

public java.util.Collection<ProcessObject> getProcesses(java.lang.String processIdentifier)
                                                 throws AdminException
Description copied from interface: MonitoringAdmin
Get the processes that correspond to the specified identifier pattern.

Specified by:
getProcesses in interface MonitoringAdmin
Parameters:
processIdentifier - the unique identifier for for a ProcessObject in the system or "WILDCARD" if all Processes are desired.
Returns:
Collection of ProcessObject
Throws:
AdminException - if there's a system error.

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()

changeVDBStatus

protected void changeVDBStatus(java.lang.String name,
                               java.lang.String version,
                               int status)
                        throws AdminException
Throws:
AdminException
Overview  Package   Class  Use  Tree  Deprecated  Index  Help 
 PREV CLASS   NEXT CLASS FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD
Copyright © 2009. All Rights Reserved.