X-Git-Url: http://wamblee.org/gitweb/?a=blobdiff_plain;ds=sidebyside;f=system%2Fgeneral%2Fsrc%2Ftest%2Fjava%2Forg%2Fwamblee%2Fsystem%2Fcore%2FEnvironment.java;fp=system%2Fgeneral%2Fsrc%2Ftest%2Fjava%2Forg%2Fwamblee%2Fsystem%2Fcore%2FEnvironment.java;h=2fa1c4cf374471412837905cfa76ffe30bf676d9;hb=4845c677310814de4c98e22aad483e49b9dfc594;hp=0000000000000000000000000000000000000000;hpb=b0e1c060d6207c0fc06e4673764a6980da775210;p=utils diff --git a/system/general/src/test/java/org/wamblee/system/core/Environment.java b/system/general/src/test/java/org/wamblee/system/core/Environment.java new file mode 100644 index 00000000..2fa1c4cf --- /dev/null +++ b/system/general/src/test/java/org/wamblee/system/core/Environment.java @@ -0,0 +1,65 @@ +/* + * 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.core; + +import javax.sql.DataSource; + +import org.wamblee.system.core.AbstractComponent; +import org.wamblee.system.core.DefaultProvidedInterface; +import org.wamblee.system.core.ProvidedInterface; +import org.wamblee.system.core.RequiredInterface; +import org.wamblee.test.EventTracker; + + +public class Environment extends AbstractComponent { + + private static final ProvidedInterface[] provided() { + return new ProvidedInterface[] { + new DefaultProvidedInterface("datasource", DataSource.class), + new DefaultProvidedInterface("integer", Integer.class) + }; + } + + private EventTracker _tracker; + + public Environment() { + super("environment", provided(), new RequiredInterface[0]); + } + + public Environment(EventTracker aTracker) { + this(); + _tracker = aTracker; + } + + @Override + protected void doStart() { + addService(getProvidedServices()[0], new Integer(1)); + addService(getProvidedServices()[1], new Integer(2)); + track("start." + getName()); + } + + @Override + protected void doStop() { + track("stop." + getName()); + } + + private void track(String aString) { + if ( _tracker == null ) { + return; + } + _tracker.eventOccurred(aString); + } +}