User: ejort
Date: 02/02/01 19:16:22
Added: src/main/org/jboss/test/jbossmx/compliance/monitor
BasicTestCase.java
Log:
JBossMX tests, temporary modifications to classpaths see comment in build.xml
Revision Changes Path
1.1
jbosstest/src/main/org/jboss/test/jbossmx/compliance/monitor/BasicTestCase.java
Index: BasicTestCase.java
===================================================================
/*
* JBoss, the OpenSource J2EE webOS
*
* Distributable under LGPL license.
* See terms of license at gnu.org.
*/
package org.jboss.test.jbossmx.compliance.monitor;
import org.jboss.test.jbossmx.compliance.TestCase;
import org.jboss.test.jbossmx.compliance.monitor.support.CounterSupport;
import org.jboss.test.jbossmx.compliance.monitor.support.StringSupport;
import java.util.ArrayList;
import javax.management.Attribute;
import javax.management.AttributeList;
import javax.management.MBeanServer;
import javax.management.MBeanServerFactory;
import javax.management.Notification;
import javax.management.NotificationListener;
import javax.management.ObjectName;
import javax.management.monitor.CounterMonitor;
import javax.management.monitor.GaugeMonitor;
import javax.management.monitor.StringMonitor;
/**
* Basic monitor test.<p>
*
* The aim of these tests is to check the most common uses of the monitor
* services.
*
* @author <a href="mailto:[EMAIL PROTECTED]";>Adrian Brock</a>.
*/
public class BasicTestCase
extends TestCase
implements NotificationListener
{
// Attributes ----------------------------------------------------------------
/**
* The object name of the monitor service
*/
ObjectName monitorName;
/**
* The MBean server
*/
MBeanServer server;
/**
* The observed object
*/
Object monitored;
/**
* The observed object name
*/
ObjectName observedObject;
/**
* The observed attribute
*/
String observedAttribute;
/**
* The received notifications
*/
ArrayList receivedNotifications = new ArrayList();
// Constructor ---------------------------------------------------------------
public BasicTestCase(String s)
{
super(s);
}
// Tests ---------------------------------------------------------------------
/**
* Test simple counter notification.
*/
public void testCounterSimpleNotification()
{
try
{
monitored = new CounterSupport();
observedObject = new ObjectName("Monitor:type=CounterSupport");
observedAttribute = "Value";
startCounterService(false, 0, 0, 10);
sleep(WAIT);
assertEquals(0, receivedNotifications.size());
setAttribute(new Integer(10));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(9));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(10));
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
}
catch (Exception e)
{
fail(e.toString());
}
finally
{
stopMonitorService();
}
}
/**
* Test a counter in difference mode.
*/
public void testCounterDifferenceNotification()
{
try
{
monitored = new CounterSupport();
observedObject = new ObjectName("Monitor:type=CounterSupport");
observedAttribute = "Value";
startCounterService(true, 0, 0, 10);
sleep(WAIT);
assertEquals(0, receivedNotifications.size());
setAttribute(new Integer(10));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(9));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(10));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(20));
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
}
catch (Exception e)
{
fail(e.toString());
}
finally
{
stopMonitorService();
}
}
/**
* Test simple gauge notification high and low.
*/
public void testGaugeSimpleBothNotification()
{
try
{
monitored = new CounterSupport();
observedObject = new ObjectName("Monitor:type=GaugeSupport");
observedAttribute = "Value";
startGaugeService(true, true, false, 10, 0);
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(10));
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
setAttribute(new Integer(9));
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
setAttribute(new Integer(10));
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
setAttribute(new Integer(0));
sleep(WAIT);
assertEquals(3, receivedNotifications.size());
setAttribute(new Integer(1));
sleep(WAIT);
assertEquals(3, receivedNotifications.size());
setAttribute(new Integer(0));
sleep(WAIT);
assertEquals(3, receivedNotifications.size());
}
catch (Exception e)
{
fail(e.toString());
}
finally
{
stopMonitorService();
}
}
/**
* Test simple gauge notification high.
*/
public void testGaugeSimpleHighNotification()
{
try
{
monitored = new CounterSupport();
observedObject = new ObjectName("Monitor:type=GaugeSupport");
observedAttribute = "Value";
startGaugeService(true, false, false, 10, 0);
sleep(WAIT);
assertEquals(0, receivedNotifications.size());
setAttribute(new Integer(10));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(9));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(10));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(0));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(10));
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
}
catch (Exception e)
{
fail(e.toString());
}
finally
{
stopMonitorService();
}
}
/**
* Test simple gauge notification low.
*/
public void testGaugeSimpleLowNotification()
{
try
{
monitored = new CounterSupport();
observedObject = new ObjectName("Monitor:type=GaugeSupport");
observedAttribute = "Value";
startGaugeService(false, true, false, 10, 0);
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(10));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(9));
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute(new Integer(0));
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
setAttribute(new Integer(1));
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
setAttribute(new Integer(0));
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
}
catch (Exception e)
{
fail(e.toString());
}
finally
{
stopMonitorService();
}
}
/**
* Test a String notification (both match and differ).
*/
public void testStringBothNotification()
{
try
{
monitored = new StringSupport();
observedObject = new ObjectName("Monitor:type=StringSupport");
observedAttribute = "Value";
startStringService(true, true, "test");
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute("test");
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
setAttribute("not-test");
sleep(WAIT);
assertEquals(3, receivedNotifications.size());
}
catch (Exception e)
{
fail(e.toString());
}
finally
{
stopMonitorService();
}
}
/**
* Test a String notification (just match).
*/
public void testStringMatchNotification()
{
try
{
monitored = new StringSupport();
observedObject = new ObjectName("Monitor:type=StringSupport");
observedAttribute = "Value";
startStringService(true, false, "test");
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute("test");
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
setAttribute("not-test");
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
}
catch (Exception e)
{
fail(e.toString());
}
finally
{
stopMonitorService();
}
}
/**
* Test a String notification (just differ).
*/
public void testStringDifferNotification()
{
try
{
monitored = new StringSupport();
observedObject = new ObjectName("Monitor:type=StringSupport");
observedAttribute = "Value";
startStringService(false, true, "test");
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute("test");
sleep(WAIT);
assertEquals(1, receivedNotifications.size());
setAttribute("not-test");
sleep(WAIT);
assertEquals(2, receivedNotifications.size());
}
catch (Exception e)
{
fail(e.toString());
}
finally
{
stopMonitorService();
}
}
// Support functions ---------------------------------------------------------
/**
* Start a counter service
* @param mode the difference mode
* @param modulus for counters that wrap
* @param offset the offset value
* @param threshold the threshold value
*/
private void startCounterService(boolean mode, int modulus,
int offset, int threshold)
throws Exception
{
installMonitorService(new CounterMonitor());
AttributeList attributes = new AttributeList();
attributes.add(new Attribute("DifferenceMode", new Boolean(mode)));
attributes.add(new Attribute("Modulus", new Integer(modulus)));
attributes.add(new Attribute("Offset", new Integer(offset)));
attributes.add(new Attribute("Notify", new Boolean(true)));
attributes.add(new Attribute("Threshold", new Integer(threshold)));
attributes.add(new Attribute("GranularityPeriod", new Long(PERIOD)));
attributes.add(new Attribute("ObservedObject", observedObject));
attributes.add(new Attribute("ObservedAttribute", observedAttribute));
int before = attributes.size();
attributes = server.setAttributes(monitorName, attributes);
assertEquals(before, attributes.size());
server.invoke(monitorName, "start", new Object[0], new String[0]);
}
/**
* Start a gauge service
* @param high notify on high
* @param low notifiy on low
* @param high notify on high
* @param differ difference mode
* @param highValue high threshold
* @param lowValue low threshold
*/
private void startGaugeService(boolean high, boolean low, boolean differ,
int highValue, int lowValue)
throws Exception
{
installMonitorService(new GaugeMonitor());
AttributeList attributes = new AttributeList();
attributes.add(new Attribute("NotifyHigh", new Boolean(high)));
attributes.add(new Attribute("NotifyLow", new Boolean(low)));
attributes.add(new Attribute("DifferenceMode", new Boolean(differ)));
attributes.add(new Attribute("GranularityPeriod", new Long(PERIOD)));
attributes.add(new Attribute("ObservedObject", observedObject));
attributes.add(new Attribute("ObservedAttribute", observedAttribute));
int before = attributes.size();
attributes = server.setAttributes(monitorName, attributes);
assertEquals(before, attributes.size());
server.invoke(monitorName, "setThresholds",
new Object[] { new Integer(highValue), new Integer(lowValue) },
new String[] { "java.lang.Number", "java.lang.Number" });
server.invoke(monitorName, "start", new Object[0], new String[0]);
}
/**
* Start a string service
* @param match notify on match
* @param differ notifiy on differ
* @param value the value to check
*/
private void startStringService(boolean match, boolean differ,
String value)
throws Exception
{
installMonitorService(new StringMonitor());
AttributeList attributes = new AttributeList();
attributes.add(new Attribute("NotifyDiffer", new Boolean(differ)));
attributes.add(new Attribute("NotifyMatch", new Boolean(match)));
attributes.add(new Attribute("StringToCompare", value));
attributes.add(new Attribute("GranularityPeriod", new Long(PERIOD)));
attributes.add(new Attribute("ObservedObject", observedObject));
attributes.add(new Attribute("ObservedAttribute", observedAttribute));
int before = attributes.size();
attributes = server.setAttributes(monitorName, attributes);
assertEquals(before, attributes.size());
server.invoke(monitorName, "start", new Object[0], new String[0]);
}
/**
* Get an MBeanServer, install the monitor service and a notification
* listener.
* @param monitor the object doing the monitoring
*/
private void installMonitorService(Object monitor)
throws Exception
{
server = MBeanServerFactory.createMBeanServer("Monitor");
monitorName = new ObjectName("Monitor:type=MonitorService");
server.registerMBean(monitor, monitorName);
receivedNotifications.clear();
server.addNotificationListener(monitorName, this, null, null);
server.registerMBean(monitored, observedObject);
}
/**
* Remove everything used by this test. Cannot report failures because
* the test might have failed earlier.
*/
private void stopMonitorService()
{
try
{
server.invoke(monitorName, "stop", new Object[0], new String[0]);
server.removeNotificationListener(monitorName, this);
server.unregisterMBean(observedObject);
server.unregisterMBean(monitorName);
MBeanServerFactory.releaseMBeanServer(server);
}
catch (Exception ignored) {}
}
/**
* Set an attribute
* @param value the value to set
*/
private void setAttribute(Object value)
throws Exception
{
Attribute attribute = new Attribute(observedAttribute, value);
server.setAttribute(observedObject, attribute);
}
/**
* Handle a notification, just add it to the list
*
* @param notification the notification received
* @param handback not used
*/
public void handleNotification(Notification notification, Object handback)
{
receivedNotifications.add(notification);
}
/**
* Calculate the time using an offset from the current time.
* @param offset the offset from the current time
* @return the calculated time
*/
private long calcTime(long offset)
{
return System.currentTimeMillis() + offset;
}
/**
* Sleep for some time.
* @param sleep the number of millis to sleep.
*/
private void sleep(long sleep)
{
try
{
Thread.currentThread().sleep(sleep);
}
catch (InterruptedException ignored) {}
}
}
_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development
