import java.util.Map;
import java.util.Set;
import java.util.concurrent.CompletableFuture;
+import java.util.concurrent.CompletionStage;
import java.util.function.Consumer;
+import java.util.function.Supplier;
/**
* A wrapper for an object, whose dependencies and life cycle can be managed.
*/
-public class Component<I> {
+public class Component<I> implements Supplier<I>, Comparable<Component<?>> {
private final I instance;
private final Map<Class<? super I>, PublishedType<? super I>> types;
private final Set<Dependency<?>> dependencies;
+ private final Map<String, Object> properties;
private CompletableFuture<Void> activationStarted = null;
private CompletableFuture<Void> activated = null;
private CompletableFuture<Void> deactivationStarted = null;
private CompletableFuture<Void> deactivated = null;
+ // internal
private Set<Dependency<?>> dependants = new HashSet<>();
- Component(Consumer<Component<?>> register, I instance, Runnable init, Runnable close,
- Set<Dependency<?>> dependencies, Set<Class<? super I>> classes) {
+ private RankingKey rankingKey;
+
+ Component(ComponentRegister register, I instance, Runnable init, Runnable close, Set<Dependency<?>> dependencies,
+ Set<Class<? super I>> classes, Map<String, Object> properties) {
assert instance != null;
assert init != null;
assert close != null;
// TODO check whether context is active, so that we start right away
prepareNextActivation();
- register.accept(this);
+ long serviceId = register.register(this);
+ Map<String, Object> props = new HashMap<>(properties);
+ props.put(RankingKey.SERVICE_ID, serviceId);
+ this.properties = Collections.unmodifiableMap(props);
+ rankingKey = new RankingKey(properties);
}
private void prepareNextActivation() {
dependants.add(dependant);
}
- public I getInstance() {
+ @Override
+ public I get() {
return instance;
}
return types.containsKey(clss);
}
+ public Map<String, Object> getProperties() {
+ return properties;
+ }
+
+ @Override
+ public int compareTo(Component<?> o) {
+ return rankingKey.compareTo(rankingKey);
+ }
+
/** A type which has been explicitly exposed by a component. */
public static class PublishedType<T> {
private Component<? extends T> component;
public Class<T> getType() {
return clss;
}
+
+ public CompletionStage<T> getValue() {
+ return value.minimalCompletionStage();
+ }
}
/** Builds a {@link Component}. */
- public static class Builder<I> {
+ public static class Builder<I> implements Supplier<I> {
private final I instance;
private Runnable init;
private Set<Dependency<?>> dependencies = new HashSet<>();
private Set<Class<? super I>> types = new HashSet<>();
+ private final Map<String, Object> properties = new HashMap<>();
public Builder(I instance) {
this.instance = instance;
}
- public Component<I> build(Consumer<Component<?>> register) {
+ public Component<I> build(ComponentRegister register) {
// default values
if (types.isEmpty()) {
types.add(getInstanceClass());
};
// instantiation
- Component<I> component = new Component<I>(register, instance, init, close, dependencies, types);
+ Component<I> component = new Component<I>(register, instance, init, close, dependencies, types, properties);
for (Dependency<?> dependency : dependencies) {
dependency.type.getPublisher().addDependant(dependency);
}
return this;
}
+ public void addProperty(String key, Object value) {
+ if (properties.containsKey(key))
+ throw new IllegalStateException("Key " + key + " is already set.");
+ properties.put(key, value);
+ }
+
+ @Override
public I get() {
return instance;
}