- for (Filter filter : Lists.reverse(filters())) {
- logger.finest(String.format("Adding Listener to %s.", filter.name()));
- filter.addMetadataListener(new MetadataListener() {
-
- @Override
- public void metadataUpdated(Filter filter, Metadata metadata) {
- for (Filter sinks : filters(filter)) {
- logger.fine(String.format("Updating Metadata from %s to %s as %s.", filter.name(), sinks.name(), metadata));
- sinks.metadataUpdated(metadata);
- }
- }
- });
- }