com.cloudtran.jmx
Class Datasource

java.lang.Object
  extended by javax.management.StandardMBean
      extended by com.cloudtran.jmx.AbstractMBean
          extended by com.cloudtran.jmx.Datasource
All Implemented Interfaces:
DatasourceMBean, DynamicMBean, MBeanRegistration

public class Datasource
extends AbstractMBean
implements DatasourceMBean


Constructor Summary
Datasource(String dataSourceUrl, LinkedBlockingQueue<com.cloudtran.persist.AbstractPerDataSourceQueueEntry> queue, DSSummaryHelper summaryHelper)
           
 
Method Summary
 String getDatasourceUrl()
           
 int getMaxObjectsPerDsTransaction()
           
 boolean getPersistToDatasource()
           
 int getQueueLength()
           
 long getRowsAffectedInThisLoop()
           
 long getRowsDeletedPerSecond()
           
 long getRowsInsertedPerSecond()
           
 long getRowsUpdatedPerSecond()
           
 void setMaxObjectsPerDsTransaction(int newValue)
           
 void setPersistToDatasource(boolean newValue)
           
 
Methods inherited from class javax.management.StandardMBean
getAttribute, getAttributes, getImplementation, getImplementationClass, getMBeanInfo, getMBeanInterface, invoke, postDeregister, postRegister, preDeregister, preRegister, setAttribute, setAttributes, setImplementation
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Datasource

public Datasource(String dataSourceUrl,
                  LinkedBlockingQueue<com.cloudtran.persist.AbstractPerDataSourceQueueEntry> queue,
                  DSSummaryHelper summaryHelper)
           throws NotCompliantMBeanException
Throws:
NotCompliantMBeanException
Method Detail

getDatasourceUrl

public String getDatasourceUrl()
Specified by:
getDatasourceUrl in interface DatasourceMBean

getQueueLength

public int getQueueLength()
Specified by:
getQueueLength in interface DatasourceMBean

getRowsAffectedInThisLoop

public long getRowsAffectedInThisLoop()
Specified by:
getRowsAffectedInThisLoop in interface DatasourceMBean

getMaxObjectsPerDsTransaction

public int getMaxObjectsPerDsTransaction()
Specified by:
getMaxObjectsPerDsTransaction in interface DatasourceMBean

setMaxObjectsPerDsTransaction

public void setMaxObjectsPerDsTransaction(int newValue)
Specified by:
setMaxObjectsPerDsTransaction in interface DatasourceMBean

getRowsDeletedPerSecond

public long getRowsDeletedPerSecond()
Specified by:
getRowsDeletedPerSecond in interface DatasourceMBean

getRowsInsertedPerSecond

public long getRowsInsertedPerSecond()
Specified by:
getRowsInsertedPerSecond in interface DatasourceMBean

getRowsUpdatedPerSecond

public long getRowsUpdatedPerSecond()
Specified by:
getRowsUpdatedPerSecond in interface DatasourceMBean

getPersistToDatasource

public boolean getPersistToDatasource()
Specified by:
getPersistToDatasource in interface DatasourceMBean

setPersistToDatasource

public void setPersistToDatasource(boolean newValue)
Specified by:
setPersistToDatasource in interface DatasourceMBean