This is a basic test case for testing Plugins and the PluginRegistry with stand alone plugins. There was a bug in PluginRegistry where stopping a plugin did not remove the reference to it in the registry.
I'll be adding one tomorrow to test multiple repositories and event listening/handling. -Mark > -----Original Message----- > From: [EMAIL PROTECTED] [mailto:[EMAIL PROTECTED]] > Sent: Tuesday, December 10, 2002 11:32 PM > To: [EMAIL PROTECTED] > Subject: cvs commit: > jakarta-log4j/tests/src/java/org/apache/log4j/plugins > PluginTestCase.java > > > mwomack 2002/12/10 23:32:19 > > Added: tests/src/java/org/apache/log4j/plugins PluginTestCase.java > Log: > Added PluginTestCase. > > Revision Changes Path > 1.1 > jakarta-log4j/tests/src/java/org/apache/log4j/plugins/PluginTestCase.java > > Index: PluginTestCase.java > =================================================================== > /* > * Copyright (C) The Apache Software Foundation. All rights reserved. > * > * This software is published under the terms of the Apache Software > * License version 1.1, a copy of which has been included with this > * distribution in the LICENSE.txt file. */ > > package org.apache.log4j.plugins; > > import java.io.File; > import java.io.IOException; > > import junit.framework.TestCase; > import junit.framework.TestSuite; > import junit.framework.Test; > > import org.apache.log4j.util.Compare; > > import org.apache.log4j.FileAppender; > import org.apache.log4j.Logger; > import org.apache.log4j.Hierarchy; > import org.apache.log4j.Level; > import org.apache.log4j.SimpleLayout; > import org.apache.log4j.PatternLayout; > import org.apache.log4j.spi.LoggerRepository; > import org.apache.log4j.spi.RootCategory; > > public class PluginTestCase extends TestCase { > > static String FILE = "output/plugins.PluginTestCase"; > static String WITNESS = "witness/plugins.PluginTestCase"; > > public PluginTestCase(String name) { > super(name); > } > > public void setUp() { > // delete the output file if they happen to exist > File file = new File(getOutputFile("test1")); > file.delete(); > } > > private String getOutputFile(String caseName) { > return FILE + "." + caseName + ".txt"; > } > > private String getWitnessFile(String caseName) { > return WITNESS + "." + caseName + ".txt"; > } > > private void setupAppender(String caseName) throws IOException { > Logger root = Logger.getRootLogger(); > root.removeAllAppenders(); > > // set up appender > FileAppender appender = new FileAppender(new SimpleLayout(), > getOutputFile(caseName), false); > //FileAppender appender = new FileAppender(new > PatternLayout("%c{1}: %m%n"), > // getOutputFile(caseName), false); > > root.addAppender(appender); > root.setLevel(Level.DEBUG); > } > > // basic test of plugin in standalone mode > public void test1() throws Exception { > String testName = "test1"; > Logger logger = Logger.getLogger(testName); > > setupAppender(testName); > > PluginTester plugin1 = new PluginTester1("plugin1", 1); > PluginTester plugin2 = new PluginTester1("plugin1", 2); > PluginTester plugin3 = new PluginTester2("plugin1", 3); > PluginTester plugin4 = new PluginTester2("plugin2", 4); > PluginTester retPlugin; > > // test basic starting/stopping > logger.info("test 1.1 - basic starting/stopping"); > logger.info("starting " + plugin1.getIdentifier()); > PluginRegistry.startPlugin(plugin1); > logger.info("stopping " + plugin1.getIdentifier()); > PluginRegistry.stopPlugin(plugin1); > > // test restarting and starting when already started > logger.info("test 1.2 - restarting and starting when > already started"); > logger.info("restarting " + plugin1.getIdentifier()); > PluginRegistry.startPlugin(plugin1); > logger.info("restarting " + plugin1.getIdentifier() + " again"); > PluginRegistry.startPlugin(plugin1); > > // test stopping and stopping when already stopped > logger.info("test 1.3- stopping and stopping when already stopped"); > logger.info("stopping " + plugin1.getIdentifier()); > PluginRegistry.stopPlugin(plugin1); > logger.info("stopping " + plugin1.getIdentifier() + " again"); > PluginRegistry.stopPlugin(plugin1); > > // test starting of an "equal" plugin > logger.info("test 1.4 - starting of an \"equal\" plugin"); > logger.info("starting " + plugin1.getIdentifier()); > retPlugin = (PluginTester)PluginRegistry.startPlugin(plugin1); > logger.info("returned plugin is " + retPlugin.getIdentifier()); > logger.info("starting " + plugin2.getIdentifier()); > retPlugin = (PluginTester)PluginRegistry.startPlugin(plugin2); > logger.info("returned plugin is " + retPlugin.getIdentifier()); > logger.info("stopping " + plugin1.getIdentifier()); > PluginRegistry.stopPlugin(plugin1); > > // test starting an "equal" plugin after original stopped > logger.info("test 1.5 - starting an \"equal\" plugin after > original stopped"); > logger.info("starting " + plugin2.getIdentifier()); > PluginRegistry.startPlugin(plugin2); > logger.info("stopping " + plugin2.getIdentifier()); > PluginRegistry.stopPlugin(plugin2); > > // test starting of an "unequal" plugin with same name > logger.info("test 1.6 - starting of an \"unequal\" plugin > with same name"); > logger.info("starting " + plugin1.getIdentifier()); > retPlugin = (PluginTester)PluginRegistry.startPlugin(plugin1); > logger.info("returned plugin is " + retPlugin.getIdentifier()); > logger.info("starting " + plugin3.getIdentifier()); > retPlugin = (PluginTester)PluginRegistry.startPlugin(plugin3); > logger.info("returned plugin is " + retPlugin.getIdentifier()); > logger.info("stopping " + plugin3.getIdentifier()); > PluginRegistry.stopPlugin(plugin3); > > // test starting of multiple plugins and stopAll > logger.info("test 1.7 - starting of multiple plugins and stopAll"); > logger.info("starting " + plugin1.getIdentifier()); > retPlugin = (PluginTester)PluginRegistry.startPlugin(plugin1); > logger.info("starting " + plugin4.getIdentifier()); > retPlugin = (PluginTester)PluginRegistry.startPlugin(plugin4); > logger.info("stopping all plugins"); > PluginRegistry.stopAllPlugins(); > logger.info("stopping all plugins again"); > PluginRegistry.stopAllPlugins(); > > assertTrue(Compare.compare(getOutputFile(testName), > getWitnessFile(testName))); > } > > /* > System.out.println("creating the sink repository"); > LoggerRepository repo1 = new Hierarchy(new > RootCategory(Level.DEBUG)); > System.out.println("configuring the sink repository"); > configurator.doConfigure("input/sink.xml",repo1); > > System.out.println("creating the source repository"); > LoggerRepository repo2 = new Hierarchy(new > RootCategory(Level.DEBUG)); > System.out.println("configuring the source repository"); > configurator.doConfigure("input/source.xml",repo2); > > System.out.println("sending messages via source loggers"); > Logger logger = repo2.getLogger("repo2.logger"); > logger.debug("Message 1"); > logger.debug("Message 2"); > logger = repo2.getLogger("repo2.logger2"); > logger.debug("Message 3"); > logger.debug("Message 4"); > > System.out.println("sending messages via sink loggers"); > logger = repo1.getLogger("repo1.logger"); > logger.debug("Message 5"); > logger.debug("Message 6"); > logger = repo1.getLogger("repo1.logger2"); > logger.debug("Message 7"); > logger.debug("Message 8"); > > Thread.currentThread().sleep(5000); > > repo2.shutdown(); > repo1.shutdown(); > */ > > public static Test suite() { > TestSuite suite = new TestSuite(); > suite.addTest(new PluginTestCase("test1")); > return suite; > } > > /** > Class to test the Plugin and PluginRegistry functionality. */ > private static class PluginTester extends PluginSkeleton { > protected Logger logger; > > private boolean active = false; > public int id; > > // test to see if the given obj "equals" this object > // considered equal if same class, same name and same > // repository > public boolean equals(Object obj) { > if (!(obj.getClass() == this.getClass())) > return false; > > Plugin plugin = (PluginTester)obj; > > if (!this.getName().equals(plugin.getName())) > return false; > > if > (!this.getLoggerRepository().equals(plugin.getLoggerRepository())) > return false; > > return true; > } > > public synchronized boolean isActive() { > logger.debug("plugin " + this.getIdentifier() + " is " + > (active ? "active" : "inactive")); > return active; > } > > private synchronized boolean setActive(boolean _active) { > if (active != _active) { > active = _active; > return true; > } > else { > return false; > } > } > > public String getIdentifier() { > return this.getName() + "-id" + id; > } > > public void activateOptions() { > if (setActive(true)) { > logger.debug("plugin " + this.getIdentifier() + " activated"); > } > else { > logger.debug("plugin " + this.getIdentifier() + " > already activated"); > } > } > > public void shutdown() { > if (setActive(false)) { > logger.debug("plugin " + this.getIdentifier() + " shutdown"); > } > else { > logger.debug("plugin " + this.getIdentifier() + " > already shutdown"); > } > } > } > > /** > Class to test the Plugin and PluginRegistry functionality. */ > private static class PluginTester1 extends PluginTester { > > public PluginTester1(String _name, int _id) { > logger = Logger.getLogger(this.getClass()); > setName(_name); > id = _id; > } > > } > > /** > Class to test the Plugin and PluginRegistry functionality. */ > private static class PluginTester2 extends PluginTester { > > public PluginTester2(String _name, int _id) { > logger = Logger.getLogger(this.getClass()); > setName(_name); > id = _id; > } > > } > } > > > > -- > To unsubscribe, e-mail: > <mailto:[EMAIL PROTECTED]> > For additional commands, e-mail: > <mailto:[EMAIL PROTECTED]> > -- To unsubscribe, e-mail: <mailto:[EMAIL PROTECTED]> For additional commands, e-mail: <mailto:[EMAIL PROTECTED]>
