Sha256: f12dd02a64b6fa58cac6e344cd2eefbdcb71810814d019fd9ed810cb9aa0e960
Contents?: true
Size: 1.49 KB
Versions: 12
Compression:
Stored size: 1.49 KB
Contents
package org.embulk.plugin;
import java.util.Set;
import java.util.List;
import java.util.ArrayList;
import com.google.common.collect.ImmutableList;
import com.google.inject.Inject;
import com.google.inject.Injector;
import org.embulk.config.ConfigException;
public class PluginManager
{
private final List<PluginSource> sources;
private final Injector injector;
// Set<PluginSource> is injected BuiltinPluginSourceModule or extensions
// using Multibinder<PluginSource>.
@Inject
public PluginManager(Set<PluginSource> pluginSources, Injector injector)
{
this.sources = ImmutableList.copyOf(pluginSources);
this.injector = injector;
}
public <T> T newPlugin(Class<T> iface, PluginType type)
{
if (sources.isEmpty()) {
throw new ConfigException("No PluginSource is installed");
}
List<Throwable> causes = new ArrayList<Throwable>();
for (PluginSource source : sources) {
try {
return source.newPlugin(iface, type);
} catch (PluginSourceNotMatchException e) {
if (e.getCause() != null) {
causes.add(e.getCause());
}
}
}
ConfigException e = new ConfigException(String.format("%s '%s' is not found",
iface.getSimpleName(), type.getName()), causes.remove(causes.size()-1));
for (Throwable cause : causes) {
e.addSuppressed(cause);
}
throw e;
}
}
Version data entries
12 entries across 12 versions & 1 rubygems