X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;f=system%2Fgeneral%2Fsrc%2Ftest%2Fjava%2Forg%2Fwamblee%2Fsystem%2FSystemAssemblerTest.java;h=c67529b875b6a7e1819ce30b4e25427a16659696;hb=6f8bb575523e672b9f8797e543f7c59d15db7253;hp=9412caee08a58029eb5fb9d825ab56099e6f6051;hpb=2aa6c38d06e981a4a6c240e2d371638205c3fb54;p=utils diff --git a/system/general/src/test/java/org/wamblee/system/SystemAssemblerTest.java b/system/general/src/test/java/org/wamblee/system/SystemAssemblerTest.java index 9412caee..c67529b8 100644 --- a/system/general/src/test/java/org/wamblee/system/SystemAssemblerTest.java +++ b/system/general/src/test/java/org/wamblee/system/SystemAssemblerTest.java @@ -1,3 +1,18 @@ +/* + * Copyright 2007 the original author or authors. + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ package org.wamblee.system; import java.io.Serializable; @@ -6,14 +21,18 @@ import java.util.Arrays; import org.wamblee.system.Component.Status; import org.wamblee.test.AssertionUtils; +import org.wamblee.test.EventTracker; import junit.framework.TestCase; public class SystemAssemblerTest extends TestCase { + private EventTracker _tracker; + @Override protected void setUp() throws Exception { super.setUp(); + _tracker = new EventTracker(); } private static class MyMultiple implements Serializable, Runnable { @@ -24,16 +43,16 @@ public class SystemAssemblerTest extends TestCase { } public void testFilterProvided() { - RequiredInterface req1 = new DefaultRequiredInterfaceDescriptor("name", + RequiredInterface req1 = new DefaultRequiredInterface("name", + Runnable.class); + RequiredInterface req2 = new DefaultRequiredInterface("name", + Serializable.class); + ProvidedInterface prov1 = new DefaultProvidedInterface("name", Runnable.class); - RequiredInterface req2 = new DefaultRequiredInterfaceDescriptor("name", + ProvidedInterface prov2 = new DefaultProvidedInterface("name", Serializable.class); - ProvidedInterface prov1 = new DefaultProvidedInterfaceDescriptor( - "name", Runnable.class); - ProvidedInterface prov2 = new DefaultProvidedInterfaceDescriptor( - "name", Serializable.class); - ProvidedInterface prov3 = new DefaultProvidedInterfaceDescriptor( - "name", MyMultiple.class); + ProvidedInterface prov3 = new DefaultProvidedInterface("name", + MyMultiple.class); AssertionUtils.assertEquals(new RequiredInterface[] { req1 }, SystemAssembler.filterRequiredServices(prov1, Arrays @@ -57,19 +76,19 @@ public class SystemAssemblerTest extends TestCase { } public void testEnvironmentApplication() { - Component environment = new Environment(); - Component application = new Application(); + Component environment = new Environment(_tracker); + Component application = new Application(_tracker); SystemAssembler assembler = new SystemAssembler(new Component[] { environment, application }, new ProvidedInterface[0]); assembler.start(); + AssertionUtils.assertEquals(new String[] { "start.environment", + "start.application" }, _tracker.getEvents( + Thread.currentThread()).toArray(new String[0])); ProvidedInterface[] envServices = environment.getRunningServices(); assertEquals(2, envServices.length); ProvidedInterface[] appServices = environment.getRunningServices(); assertEquals(2, appServices.length); - - // TODO test stopping!!!!!! - environment.stop(); - application.stop(); + } public void testApplicationEnvironment() { @@ -87,10 +106,12 @@ public class SystemAssemblerTest extends TestCase { } public void testComposite() { - Component environment = new Environment(); - Component application = new Application(); + Component environment = new Environment(_tracker); + Component application = new Application(_tracker); + assertEquals(0, _tracker.getEventCount()); assertEquals(Status.NOT_STARTED, environment.getStatus()); assertEquals(Status.NOT_STARTED, application.getStatus()); + Container system = new Container("all", new Component[] { environment, application }, new ProvidedInterface[0], new RequiredInterface[0]); @@ -103,23 +124,33 @@ public class SystemAssemblerTest extends TestCase { assertEquals(Status.RUNNING, environment.getStatus()); assertEquals(Status.RUNNING, application.getStatus()); assertEquals(Status.RUNNING, system.getStatus()); - + + AssertionUtils.assertEquals( + new String[] { "start.environment", "start.application" }, + _tracker.getEvents(Thread.currentThread()).toArray(new String[0])); + _tracker.clear(); + system.stop(); assertEquals(Status.STOPPED, environment.getStatus()); assertEquals(Status.STOPPED, application.getStatus()); assertEquals(Status.STOPPED, system.getStatus()); + + AssertionUtils.assertEquals( + new String[] { "stop.application", "stop.environment" }, + _tracker.getEvents(Thread.currentThread()).toArray(new String[0])); + + } public void testCompositeWithWrongProvidedInfo() { try { Component environment = new Environment(); Component application = new Application(); - Container system = new Container( - "all", - new Component[] { environment, application }, - new ProvidedInterface[] { new DefaultProvidedInterfaceDescriptor( + Container system = new Container("all", new Component[] { + environment, application }, + new ProvidedInterface[] { new DefaultProvidedInterface( "string", String.class) }, - new DefaultRequiredInterfaceDescriptor[0]); + new DefaultRequiredInterface[0]); } catch (SystemAssemblyException e) { return; } @@ -130,11 +161,9 @@ public class SystemAssemblerTest extends TestCase { try { Component environment = new Environment(); Component application = new Application(); - Container system = new Container( - "all", - new Component[] { environment, application }, - new ProvidedInterface[0], - new RequiredInterface[] { new DefaultRequiredInterfaceDescriptor( + Container system = new Container("all", new Component[] { + environment, application }, new ProvidedInterface[0], + new RequiredInterface[] { new DefaultRequiredInterface( "string", String.class) }); system.start("root"); } catch (SystemAssemblyException e) { @@ -146,14 +175,12 @@ public class SystemAssemblerTest extends TestCase { public void testCompositeWithSuperfluousRequiredInfo() { Component environment = new Environment(); Component application = new Application(); - Container system = new Container( - "all", - new Component[] { environment, application }, - new ProvidedInterface[0], - new RequiredInterface[] { new DefaultRequiredInterfaceDescriptor( + Container system = new Container("all", new Component[] { environment, + application }, new ProvidedInterface[0], + new RequiredInterface[] { new DefaultRequiredInterface( "string", String.class) }); - system.getRequiredServices()[0].setProvider( - new DefaultProvidedInterfaceDescriptor("hallo", String.class)); + system.getRequiredServices()[0] + .setProvider(new DefaultProvidedInterface("hallo", String.class)); system.start("root"); RequiredInterface[] required = system.getRequiredServices(); assertEquals(1, required.length); @@ -184,9 +211,11 @@ public class SystemAssemblerTest extends TestCase { new Component[] { application }, new ProvidedInterface[0], application.getRequiredServices()); environment.start("env"); - system.getRequiredServices()[0].setProvider(environment.getProvidedServices()[0]); - system.getRequiredServices()[1].setProvider(environment.getProvidedServices()[1]); - + system.getRequiredServices()[0].setProvider(environment + .getProvidedServices()[0]); + system.getRequiredServices()[1].setProvider(environment + .getProvidedServices()[1]); + system.start("root"); RequiredInterface[] required = system.getRequiredServices(); assertEquals(2, required.length);