[teiid-commits] teiid SVN: r957 - in trunk/common-internal/src/main/java/com/metamatrix/common: stats and 1 other directory.

[teiid-commits at lists.jboss.org]

Author: vhalbert at 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