- this.sinks = Preconditions.checkNotNull(sinks, "sinks must not be null");
- for (ControlledComponent component : Lists.reverse(components())) {
- logger.finest(String.format("Adding Listener to %s.", component.name()));
- component.addMetadataListener(new MetadataListener() {
- @Override
- public void metadataUpdated(ControlledComponent component, Metadata metadata) {
- if (!(component instanceof Source)) {
- return;
- }
- for (ControlledComponent controlledComponent : sinks((Source) component)) {
- logger.fine(String.format("Updating Metadata from %s to %s as %s.", component.name(), controlledComponent.name(), metadata));
- controlledComponent.metadataUpdated(metadata);
- }
- }
- });
- }