2 * Copyright 2007 the original author or authors.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
16 package org.wamblee.system.core;
18 import java.util.ArrayList;
19 import java.util.Arrays;
20 import java.util.HashSet;
21 import java.util.List;
24 import org.apache.commons.logging.Log;
25 import org.apache.commons.logging.LogFactory;
28 * Abstract subsystem class making it easy to implement new subsystems.
30 public abstract class AbstractComponent implements Component {
32 private static final Log LOG = LogFactory.getLog(AbstractComponent.class);
34 private String _context;
36 private List<ProvidedInterface> _provided;
37 private List<RequiredInterface> _required;
38 private Set<ProvidedInterface> _running;
41 * Constructs the subsystem.
50 protected AbstractComponent(String aName, ProvidedInterface[] aProvided,
51 RequiredInterface[] aRequired) {
54 _provided = new ArrayList<ProvidedInterface>();
55 _provided.addAll(Arrays.asList(aProvided));
56 _required = new ArrayList<RequiredInterface>();
57 _required.addAll(Arrays.asList(aRequired));
58 _running = new HashSet<ProvidedInterface>();
62 public final String getName() {
67 public void addContext(String aContext) {
68 if (_context == null ) {
72 _context = aContext + "." + _context;
77 public String getQualifiedName() {
78 if ( _context == null ) {
81 return _context + "." + getName();
85 public final ProvidedInterface[] getProvidedInterfaces() {
86 return _provided.toArray(new ProvidedInterface[0]);
90 public final RequiredInterface[] getRequiredInterfaces() {
91 return _required.toArray(new RequiredInterface[0]);
95 public final void start() {
96 LOG.info("Initializing '" + getQualifiedName() + "'");
98 if ( _running.size() != _provided.size()) {
99 List<ProvidedInterface> remaining =
100 new ArrayList<ProvidedInterface>(_provided);
101 remaining.removeAll(_running);
102 throw new SystemAssemblyException(getQualifiedName() + ": not all services were started, missing " + remaining);
107 * Must be implemented for initializing the subsystem. The implementation
108 * must call {@link #addService(Service)} for each service that is started.
110 protected abstract void doStart();
113 * Implementations must call this method to indicate that a new service has
119 protected final void addInterface(
120 ProvidedInterface aDescriptor, Object aService) {
121 LOG.info("Interface '" + getQualifiedName() + "." + aDescriptor.getName() + "' started.");
122 _running.add(aDescriptor);
123 aDescriptor.publish(aService);
127 public ProvidedInterface[] getRunningInterfaces() {
128 return _running.toArray(new ProvidedInterface[0]);
134 if ( _running.size() > 0 ) {
135 // programming error.
136 throw new RuntimeException(getQualifiedName() + ": still services running after the stop call.");
140 protected abstract void doStop();
143 * Implementations must call this method to indicate that a running service has
149 protected final void removeInterface(
150 ProvidedInterface aDescriptor) {
151 LOG.info("Interface '" + getQualifiedName() + "." + aDescriptor.getName() + "' stopped.");
152 _running.remove(aDescriptor);
153 aDescriptor.publish(null);
157 public String toString() {
158 return getQualifiedName();