+/*
+ * 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;
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 ServiceRegistry _registry;
+ private EventTracker<String> _tracker;
@Override
protected void setUp() throws Exception {
super.setUp();
- _registry = new DefaultServiceRegistry();
+ _tracker = new EventTracker<String>();
}
private static class MyMultiple implements Serializable, Runnable {
}
public void testFilterProvided() {
- RequiredInterfaceDescriptor req1 = new DefaultRequiredInterfaceDescriptor(
- "name", Runnable.class);
- RequiredInterfaceDescriptor req2 = new DefaultRequiredInterfaceDescriptor(
- "name", Serializable.class);
- ProvidedInterfaceDescriptor prov1 = new DefaultProvidedInterfaceDescriptor(
- "name", Runnable.class);
- ProvidedInterfaceDescriptor prov2 = new DefaultProvidedInterfaceDescriptor(
- "name", Serializable.class);
- ProvidedInterfaceDescriptor prov3 = new DefaultProvidedInterfaceDescriptor(
- "name", MyMultiple.class);
-
- AssertionUtils.assertEquals(new RequiredInterfaceDescriptor[] { req1 },
+ RequiredInterface req1 = new DefaultRequiredInterface("name",
+ Runnable.class);
+ RequiredInterface req2 = new DefaultRequiredInterface("name",
+ Serializable.class);
+ ProvidedInterface prov1 = new DefaultProvidedInterface("name",
+ Runnable.class);
+ ProvidedInterface prov2 = new DefaultProvidedInterface("name",
+ Serializable.class);
+ ProvidedInterface prov3 = new DefaultProvidedInterface("name",
+ MyMultiple.class);
+
+ AssertionUtils.assertEquals(new RequiredInterface[] { req1 },
+ SystemAssembler.filterRequiredServices(prov1, Arrays
+ .asList(new RequiredInterface[] { req1 })));
+ AssertionUtils.assertEquals(new RequiredInterface[] { req1 },
SystemAssembler.filterRequiredServices(prov1, Arrays
- .asList(new RequiredInterfaceDescriptor[] { req1 })));
- AssertionUtils.assertEquals(new RequiredInterfaceDescriptor[] { req1 },
- SystemAssembler
- .filterRequiredServices(prov1, Arrays
- .asList(new RequiredInterfaceDescriptor[] { req1,
- req2 })));
- AssertionUtils.assertEquals(new RequiredInterfaceDescriptor[] { req1,
- req2 }, SystemAssembler.filterRequiredServices(prov3, Arrays
- .asList(new RequiredInterfaceDescriptor[] { req1, req2 })));
-
- AssertionUtils.assertEquals(new ProvidedInterfaceDescriptor[] { prov1 },
+ .asList(new RequiredInterface[] { req1, req2 })));
+ AssertionUtils.assertEquals(new RequiredInterface[] { req1, req2 },
+ SystemAssembler.filterRequiredServices(prov3, Arrays
+ .asList(new RequiredInterface[] { req1, req2 })));
+
+ AssertionUtils.assertEquals(new ProvidedInterface[] { prov1 },
+ SystemAssembler.filterProvidedServices(req1, Arrays
+ .asList(new ProvidedInterface[] { prov1 })));
+ AssertionUtils.assertEquals(new ProvidedInterface[] { prov1 },
SystemAssembler.filterProvidedServices(req1, Arrays
- .asList(new ProvidedInterfaceDescriptor[] { prov1 })));
- AssertionUtils.assertEquals(new ProvidedInterfaceDescriptor[] { prov1 },
- SystemAssembler.filterProvidedServices(req1,
- Arrays.asList(new ProvidedInterfaceDescriptor[] { prov1,
- prov2 })));
- AssertionUtils.assertEquals(new ProvidedInterfaceDescriptor[] { prov1,
- prov3 }, SystemAssembler.filterProvidedServices(req1, Arrays
- .asList(new ProvidedInterfaceDescriptor[] { prov1, prov3 })));
+ .asList(new ProvidedInterface[] { prov1, prov2 })));
+ AssertionUtils.assertEquals(new ProvidedInterface[] { prov1, prov3 },
+ SystemAssembler.filterProvidedServices(req1, Arrays
+ .asList(new ProvidedInterface[] { prov1, prov3 })));
}
public void testEnvironmentApplication() {
- Component environment = new Environment(_registry);
- Component application = new Application(_registry);
+ Component environment = new Environment(_tracker);
+ Component application = new Application(_tracker);
SystemAssembler assembler = new SystemAssembler(new Component[] {
- environment, application }, new ProvidedInterfaceDescriptor[0]);
- assembler.start(_registry, new Service[0]);
- Service[] envServices = environment.getRunningServices();
+ 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);
- Service[] appServices = environment.getRunningServices();
+ ProvidedInterface[] appServices = environment.getRunningServices();
assertEquals(2, appServices.length);
- assertEquals(2, _registry.listAllServices().length);
-
- environment.stop();
- assertEquals(0, _registry.listAllServices().length);
-
- application.stop();
- assertEquals(0, _registry.listAllServices().length);
+
}
public void testApplicationEnvironment() {
try {
- Component environment = new Environment(_registry);
- Component application = new Application(_registry);
+ Component environment = new Environment();
+ Component application = new Application();
SystemAssembler assembler = new SystemAssembler(new Component[] {
- application, environment },
- new ProvidedInterfaceDescriptor[0]);
- assembler.start(_registry, new Service[0]);
+ application, environment }, new ProvidedInterface[0]);
+ assembler.start();
} catch (SystemAssemblyException e) {
// e.printStackTrace();
return;
}
public void testComposite() {
- Component environment = new Environment(_registry);
- Component application = new Application(_registry);
+ 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());
- CompositeComponent system = new CompositeComponent("all", _registry,
- new Component[] { environment, application },
- new InterfaceDescriptor[0], new InterfaceDescriptor[0]);
+
+ Container system = new Container("all", new Component[] { environment,
+ application }, new ProvidedInterface[0],
+ new RequiredInterface[0]);
assertEquals(Status.NOT_STARTED, system.getStatus());
- system.start("root", new Service[0]);
- InterfaceDescriptor[] required = system.getRequiredServices();
+ system.start("root");
+ RequiredInterface[] required = system.getRequiredServices();
assertEquals(0, required.length);
- InterfaceDescriptor[] provided = system.getProvidedServices();
+ ProvidedInterface[] provided = system.getProvidedServices();
assertEquals(0, provided.length);
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(_registry);
- Component application = new Application(_registry);
- CompositeComponent system = new CompositeComponent(
- "all",
- _registry,
- new Component[] { environment, application },
- new InterfaceDescriptor[] { new DefaultProvidedInterfaceDescriptor(
+ Component environment = new Environment();
+ Component application = new Application();
+ 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;
+ }
+ fail();
+ }
+
+ public void testCompositeRequiredInterfaceNotProvided() {
+ try {
+ Component environment = new Environment();
+ Component application = new Application();
+ 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) {
return;
}
}
public void testCompositeWithSuperfluousRequiredInfo() {
- Component environment = new Environment(_registry);
- Component application = new Application(_registry);
- CompositeComponent system = new CompositeComponent("all", _registry,
- new Component[] { environment, application },
- new InterfaceDescriptor[0],
- new InterfaceDescriptor[] { new DefaultRequiredInterfaceDescriptor(
+ Component environment = new Environment();
+ Component application = new Application();
+ Container system = new Container("all", new Component[] { environment,
+ application }, new ProvidedInterface[0],
+ new RequiredInterface[] { new DefaultRequiredInterface(
"string", String.class) });
- system.start("root", new Service[0]);
- InterfaceDescriptor[] required = system.getRequiredServices();
+ system.getRequiredServices()[0]
+ .setProvider(new DefaultProvidedInterface("hallo", String.class));
+ system.start("root");
+ RequiredInterface[] required = system.getRequiredServices();
assertEquals(1, required.length);
- InterfaceDescriptor[] provided = system.getProvidedServices();
+ ProvidedInterface[] provided = system.getProvidedServices();
assertEquals(0, provided.length);
}
public void testCompositeWithExternalDependencesNotProvided() {
try {
- Component environment = new Environment(_registry);
- Component application = new Application(_registry);
- CompositeComponent system = new CompositeComponent("all", _registry,
- new Component[] { application }, new InterfaceDescriptor[0],
+ Component environment = new Environment();
+ Component application = new Application();
+ Container system = new Container("all",
+ new Component[] { application }, new ProvidedInterface[0],
application.getRequiredServices());
- system.start("root", new Service[0]);
+ system.start("root");
} catch (SystemAssemblyException e) {
return;
}
public void testCompositeWithExternalDependencesProvided() {
- Component environment = new Environment(_registry);
- Component application = new Application(_registry);
- CompositeComponent system = new CompositeComponent("all", _registry,
- new Component[] { application }, new InterfaceDescriptor[0],
+ Component environment = new Environment();
+ Component application = new Application();
+ Container system = new Container("all",
+ new Component[] { application }, new ProvidedInterface[0],
application.getRequiredServices());
- Service[] envServices = environment.start("env", new Service[0]);
- system.start("root", envServices);
- InterfaceDescriptor[] required = system.getRequiredServices();
+ environment.start("env");
+ 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);
- InterfaceDescriptor[] provided = system.getProvidedServices();
+ ProvidedInterface[] provided = system.getProvidedServices();
assertEquals(0, provided.length);
}
public void testAmbiguousInterfaces() {
try {
- Component environment1 = new Environment(_registry);
- Component environment2 = new Environment(_registry);
- Component application = new Application(_registry);
+ Component environment1 = new Environment();
+ Component environment2 = new Environment();
+ Component application = new Application();
SystemAssembler assembler = new SystemAssembler(new Component[] {
environment1, environment2, application },
- new ProvidedInterfaceDescriptor[0]);
- assembler.start(_registry, new Service[0]);
-
+ new ProvidedInterface[0]);
+ assembler.start();
+
+ } catch (SystemAssemblyException e) {
+ return;
+ }
+ fail();
+ }
+
+ public void testIncompleteRequirements() {
+ try {
+ Component application = new Application();
+ Container system = new Container("all",
+ new Component[] { application }, new ProvidedInterface[0],
+ new RequiredInterface[0]);
+ system.start("root");
} catch (SystemAssemblyException e) {
return;
}
fail();
}
-
}
git://wamblee.org / utils / blobdiff