Modified: trunk/core/src/test/java/org/servicemix/jbi/installation/InstallationTest.java (897 => 898)
--- trunk/core/src/test/java/org/servicemix/jbi/installation/InstallationTest.java 2005-11-22 17:44:17 UTC (rev 897)
+++ trunk/core/src/test/java/org/servicemix/jbi/installation/InstallationTest.java 2005-11-22 17:47:44 UTC (rev 898)
@@ -20,8 +20,30 @@
package org.servicemix.jbi.installation;
+import org.easymock.MockControl;
import org.servicemix.jbi.container.JBIContainer;
+import org.servicemix.jbi.framework.LocalComponentConnector;
+import org.servicemix.jbi.management.ManagementContext;
+import org.servicemix.jbi.util.FileUtil;
+import javax.jbi.component.Bootstrap;
+import javax.jbi.component.Component;
+import javax.jbi.component.ComponentLifeCycle;
+import javax.jbi.management.AdminServiceMBean;
+import javax.jbi.management.InstallationServiceMBean;
+import javax.jbi.management.InstallerMBean;
+import javax.jbi.management.LifeCycleMBean;
+import javax.management.MBeanServerInvocationHandler;
+import javax.management.ObjectName;
+
+import java.io.File;
+import java.io.FileOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.jar.JarFile;
+import java.util.jar.JarOutputStream;
+import java.util.zip.ZipEntry;
+
import junit.framework.TestCase;
@@ -31,33 +53,270 @@
* @version $Revision$
*/
public class InstallationTest extends TestCase {
- protected JBIContainer container = new JBIContainer();
+ protected JBIContainer container;
/*
* @see TestCase#setUp()
*/
protected void setUp() throws Exception {
super.setUp();
+ }
+
+ /*
+ * @see TestCase#tearDown()
+ */
+ protected void tearDown() throws Exception {
+ super.tearDown();
+ shutdownContainer();
+ }
+
+ protected void startContainer(boolean clean) throws Exception {
+ shutdownContainer();
+ if (clean) {
+ FileUtil.deleteFile(new File("testWDR"));
+ }
+ container = new JBIContainer();
container.setCreateMBeanServer(true);
- container.setMonitorInstallationDirectory(true);
+ container.setMonitorInstallationDirectory(false);
container.setRootDir("testWDR");
container.init();
container.start();
+ }
+
+ protected void shutdownContainer() throws Exception {
+ if (container != null) {
+ container.shutDown();
+ }
+ }
+
+ protected File createInstallerArchive(String jbi) throws Exception {
+ InputStream is = getClass().getResourceAsStream(jbi + "-jbi.xml");
+ File jar = File.createTempFile("jbi", "zip");
+ JarOutputStream jos = new JarOutputStream(new FileOutputStream(jar));
+ jos.putNextEntry(new ZipEntry("META-INF/jbi.xml"));
+ byte[] buffer = new byte[is.available()];
+ is.read(buffer);
+ jos.write(buffer);
+ jos.closeEntry();
+ jos.close();
+ is.close();
+ return jar;
+ }
+
+ protected InstallationServiceMBean getInstallationService() throws Exception {
+ return container.getInstallationService();
+ }
+
+ protected AdminServiceMBean getAdminService() throws Exception {
+ return container.getManagementContext();
+ }
+
+
+ /**
+ * Installer should not be persistent across restart
+ * @throws Exception
+ */
+ public void testInstallerNotPersistentAcrossRestart() throws Exception {
+ ExtMockControl bootstrapMock = ExtMockControl.createControl(Bootstrap.class);
+ Bootstrap bootstrap = (Bootstrap) bootstrapMock.getMock();
+ Bootstrap1.setDelegate(bootstrap);
+ // configure bootstrap
+ bootstrap.init(null);
+ bootstrapMock.setMatcher(MockControl.ALWAYS_MATCHER);
+ bootstrapMock.replay();
+ // test component installation
+ startContainer(true);
+ String installJarUrl = createInstallerArchive("component1").getAbsolutePath();
+ ObjectName installerName = getInstallationService().loadNewInstaller(installJarUrl);
+ assertNotNull(Bootstrap1.getInstallContext());
+ assertTrue(Bootstrap1.getInstallContext().isInstall());
+ InstallerMBean installer = (InstallerMBean) MBeanServerInvocationHandler.newProxyInstance(container.getMBeanServer(), installerName, InstallerMBean.class, false);
+ assertFalse(installer.isInstalled());
+ shutdownContainer();
+ // check mocks
+ bootstrapMock.verify();
+ // configure bootstrap
+ bootstrapMock.reset();
+ bootstrapMock.replay();
+ // test container start
+ startContainer(false);
+ // check mocks
+ bootstrapMock.verify();
}
-
- public void testInstallation() throws Exception {
- Thread.sleep(2000);
+
+ /**
+ * Installer is created, component installed and server restarted
+ * @throws Exception
+ */
+ public void testInstallerInstallAndRestart() throws Exception {
+ // Create mocks
+ ExtMockControl bootstrapMock = ExtMockControl.createControl(Bootstrap.class);
+ Bootstrap bootstrap = (Bootstrap) bootstrapMock.getMock();
+ Bootstrap1.setDelegate(bootstrap);
+ ExtMockControl componentMock = ExtMockControl.createControl(Component.class);
+ Component component = (Component) componentMock.getMock();
+ Component1.setDelegate(component);
+
+ // configure bootstrap
+ bootstrapMock.reset();
+ bootstrap.init(null);
+ bootstrapMock.setMatcher(MockControl.ALWAYS_MATCHER);
+ bootstrap.onInstall();
+ bootstrap.cleanUp();
+ bootstrapMock.replay();
+ // configure component
+ componentMock.reset();
+ componentMock.replay();
+ // test component installation
+ startContainer(true);
+ String installJarUrl = createInstallerArchive("component1").getAbsolutePath();
+ ObjectName installerName = getInstallationService().loadNewInstaller(installJarUrl);
+ InstallerMBean installer = (InstallerMBean) MBeanServerInvocationHandler.newProxyInstance(container.getMBeanServer(), installerName, InstallerMBean.class, false);
+ assertFalse(installer.isInstalled());
+ ObjectName lifecycleName = installer.install();
+ LifeCycleMBean lifecycleMBean = (LifeCycleMBean) MBeanServerInvocationHandler.newProxyInstance(container.getMBeanServer(), lifecycleName, LifeCycleMBean.class, false);
+ assertEquals(LifeCycleMBean.SHUTDOWN, lifecycleMBean.getCurrentState());
+ // check mocks
+ bootstrapMock.verify();
+ componentMock.verify();
+
+ // configure bootstrap
+ bootstrapMock.reset();
+ bootstrapMock.replay();
+ // configure component
+ componentMock.reset();
+ componentMock.replay();
+ // unload installer
+ container.getInstallationService().unloadInstaller("component1", false);
+ // check mocks
+ bootstrapMock.verify();
+ componentMock.verify();
+
+ // configure bootstrap
+ bootstrapMock.reset();
+ bootstrapMock.replay();
+ // configure component
+ componentMock.reset();
+ componentMock.replay();
+ // shutdown container
+ shutdownContainer();
+ // check mocks
+ bootstrapMock.verify();
+ componentMock.verify();
+
+ // configure bootstrap
+ bootstrapMock.reset();
+ bootstrapMock.replay();
+ // configure component
+ componentMock.reset();
+ componentMock.replay();
+ // start container
+ startContainer(false);
+ lifecycleMBean = (LifeCycleMBean) MBeanServerInvocationHandler.newProxyInstance(container.getMBeanServer(), lifecycleName, LifeCycleMBean.class, false);
+ assertEquals(LifeCycleMBean.SHUTDOWN, lifecycleMBean.getCurrentState());
+ // check mocks
+ bootstrapMock.verify();
+ componentMock.verify();
}
- /*
- * @see TestCase#tearDown()
+ /**
+ * Installer is created, component installed and server restarted
+ * @throws Exception
*/
- protected void tearDown() throws Exception {
- super.tearDown();
- container.shutDown();
+ public void testInstallerInstallStartAndRestart() throws Exception {
+ // Create mocks
+ ExtMockControl bootstrapMock = ExtMockControl.createControl(Bootstrap.class);
+ Bootstrap bootstrap = (Bootstrap) bootstrapMock.getMock();
+ Bootstrap1.setDelegate(bootstrap);
+ ExtMockControl componentMock = ExtMockControl.createControl(Component.class);
+ Component component = (Component) componentMock.getMock();
+ Component1.setDelegate(component);
+ ExtMockControl lifecycleMock = ExtMockControl.createControl(ComponentLifeCycle.class);
+ ComponentLifeCycle lifecycle = (ComponentLifeCycle) lifecycleMock.getMock();
+
+ // configure bootstrap
+ bootstrapMock.reset();
+ bootstrap.init(null);
+ bootstrapMock.setMatcher(MockControl.ALWAYS_MATCHER);
+ bootstrap.onInstall();
+ bootstrap.cleanUp();
+ bootstrapMock.replay();
+ // configure component
+ componentMock.reset();
+ componentMock.replay();
+ // configure lifecycle
+ lifecycleMock.reset();
+ lifecycleMock.replay();
+ // test component installation
+ startContainer(true);
+ String installJarUrl = createInstallerArchive("component1").getAbsolutePath();
+ ObjectName installerName = getInstallationService().loadNewInstaller(installJarUrl);
+ InstallerMBean installer = (InstallerMBean) MBeanServerInvocationHandler.newProxyInstance(container.getMBeanServer(), installerName, InstallerMBean.class, false);
+ assertFalse(installer.isInstalled());
+ ObjectName lifecycleName = installer.install();
+ LifeCycleMBean lifecycleMBean = (LifeCycleMBean) MBeanServerInvocationHandler.newProxyInstance(container.getMBeanServer(), lifecycleName, LifeCycleMBean.class, false);
+ assertEquals(LifeCycleMBean.SHUTDOWN, lifecycleMBean.getCurrentState());
+ // check mocks
+ bootstrapMock.verify();
+ componentMock.verify();
+ lifecycleMock.verify();
+
+ // configure bootstrap
+ bootstrapMock.reset();
+ bootstrapMock.replay();
+ // configure component
+ componentMock.reset();
+ component.getLifeCycle();
+ componentMock.setReturnValue(lifecycle);
+ componentMock.replay();
+ // configure lifecycle
+ lifecycleMock.reset();
+ lifecycle.init(null);
+ lifecycleMock.setMatcher(MockControl.ALWAYS_MATCHER);
+ lifecycle.start();
+ lifecycleMock.replay();
+ // test component installation
+ lifecycleMBean.start();
+ assertEquals(LifeCycleMBean.RUNNING, lifecycleMBean.getCurrentState());
+ // check mocks
+ bootstrapMock.verify();
+ componentMock.verify();
+ lifecycleMock.verify();
+
+ // configure bootstrap
+ bootstrapMock.reset();
+ bootstrapMock.replay();
+ // configure component
+ componentMock.reset();
+ componentMock.replay();
+ // configure lifecycle
+ lifecycleMock.reset();
+ lifecycleMock.replay();
+ // shutdown container
+ shutdownContainer();
+ // check mocks
+ bootstrapMock.verify();
+ componentMock.verify();
+ lifecycleMock.verify();
+
+ // configure bootstrap
+ bootstrapMock.reset();
+ bootstrapMock.replay();
+ // configure component
+ componentMock.reset();
+ componentMock.replay();
+ // configure lifecycle
+ lifecycleMock.reset();
+ lifecycleMock.replay();
+ // start container
+ startContainer(false);
+ lifecycleMBean = (LifeCycleMBean) MBeanServerInvocationHandler.newProxyInstance(container.getMBeanServer(), lifecycleName, LifeCycleMBean.class, false);
+ assertEquals(LifeCycleMBean.RUNNING, lifecycleMBean.getCurrentState());
+ // check mocks
+ bootstrapMock.verify();
+ componentMock.verify();
+ lifecycleMock.verify();
}
-
-
}
