3:13 p.m.
Author: vhalbert(a)redhat.com
Date: 2009-05-16 09:13:23 -0400 (Sat, 16 May 2009)
New Revision: 957
Added:
trunk/common-internal/src/main/java/com/metamatrix/common/stats/
trunk/common-internal/src/main/java/com/metamatrix/common/stats/ConnectionPoolStats.java
Log:
Teiid-580 - adding support for monitoring connector connection pools - this is the stats
class that will be responsibile for passing the info from the server to the client
Added:
trunk/common-internal/src/main/java/com/metamatrix/common/stats/ConnectionPoolStats.java
===================================================================
---
trunk/common-internal/src/main/java/com/metamatrix/common/stats/ConnectionPoolStats.java
(rev 0)
+++
trunk/common-internal/src/main/java/com/metamatrix/common/stats/ConnectionPoolStats.java 2009-05-16
13:13:23 UTC (rev 957)
@@ -0,0 +1,145 @@
+package com.metamatrix.common.stats;
+
+import java.io.Serializable;
+
+
+public class ConnectionPoolStats implements Serializable {
+
+ public static final int NON_XA_POOL_TYPE = 0;
+ public static final int XA_POOL_TYPE = 1;
+
+ /**
+ * @since 6.1
+ */
+ private static final long serialVersionUID = -2341549955193216875L;
+
+ /**
+ * This will the name of the connector binding
+ */
+ private String connectorBindingName;
+
+
+ /**
+ * This will be identifier used in the registry to identify the connector
+ * binding and in which host and process that it's running in
+ */
+ private String connectorBindingIdentifier;
+
+
+ private int poolType;
+
+
+ // current state
+ /**
+ * Number of connections currently in use by a client
+ */
+ private int connectionInUse;
+ /**
+ * Number of connections waiting for use by a client
+ */
+ private int connectionsWaiting;
+ /**
+ * Total number of connections currently in the pool
+ */
+ private int totalConnections;
+
+
+ // total counts never reset
+ /**
+ * Total number of connections that have been destroyed since the inception of the pool
+ */
+ private int connectionsDestroyed;
+ /**
+ * Total number of connections that have been created since the inception of the pool
+ */
+ private int connectionsCreated;
+
+ /**
+ * Constructor for ConnectionPoolStats
+ * @param poolType is the connection pool type {@link #NON_XA_POOL_TYPE} or {@link
#XA_POOL_TYPE}
+ */
+ public ConnectionPoolStats(int poolType) {
+ this.poolType = poolType;
+ }
+
+ public boolean isXAPoolType() {
+ return (this.poolType==1?true:false);
+ }
+
+ public String getConnectorBindingName() {
+ return connectorBindingName;
+ }
+
+ public void setConnectorBindingName(String bindingName) {
+ this.connectorBindingName = bindingName;
+ }
+
+
+ public String getConnectorBindingIdentifier() {
+ return connectorBindingIdentifier;
+ }
+
+ public void setConnectorBindingIdentifier(String identifier) {
+ this.connectorBindingIdentifier = identifier;
+ }
+
+ public int getConnectionsInuse() {
+ return this.connectionInUse;
+ }
+
+ public int getConnectionsWaiting() {
+ return this.connectionsWaiting;
+ }
+
+ public long getConnectionsCreated() {
+ return this.connectionsCreated;
+ }
+
+ public long getConnectionsDestroyed() {
+ return this.connectionsDestroyed;
+ }
+
+ public int getTotalConnections() {
+ return this.totalConnections;
+ }
+
+ public void setConnectionsInUse(int inUseConnections) {
+ this.connectionInUse = inUseConnections;
+ }
+
+ public void setConnectionsWaiting(int waitingConnections) {
+ this.connectionsWaiting = waitingConnections;
+ }
+
+ public void setTotalConnections(int totalConnections) {
+ this.totalConnections = totalConnections;
+ }
+
+ public void setConnectionsDestroyed(int connectionsDestroyed) {
+ this.connectionsDestroyed = connectionsDestroyed;
+ }
+
+ public void setConnectionsCreated(int connectionsCreated) {
+ this.connectionsCreated = connectionsCreated;
+ }
+
+ @Override
+ /**
+ * Get string for display purposes
+ * @see java.lang.Object#toString()
+ * @since 6.1
+ */
+ public String toString() {
+ StringBuffer str = new StringBuffer();
+
+ str.append(this.connectorBindingIdentifier + "
ConnectionPoolStats:\n"); //$NON-NLS-1$
+ str.append("\tisXAPoolType = " + isXAPoolType()); //$NON-NLS-1$
+ str.append("\ttotalConnections = " + this.totalConnections);
//$NON-NLS-1$
+ str.append("\tinUseConnections = " + this.connectionInUse);
//$NON-NLS-1$
+ str.append("\twaitingConnections = " + connectionsWaiting);
//$NON-NLS-1$
+ str.append("\tconnectionsCreated = " + connectionsCreated);
//$NON-NLS-1$
+ str.append("\tconnectionsDestroyed = " + connectionsDestroyed);
//$NON-NLS-1$
+ return str.toString();
+ }
+
+}
Property changes on:
trunk/common-internal/src/main/java/com/metamatrix/common/stats/ConnectionPoolStats.java
___________________________________________________________________
Name: svn:mime-type
+ text/plain