org.apache.flume.source
Class DefaultSourceFactory

java.lang.Object
  org.apache.flume.source.DefaultSourceFactory

All Implemented Interfaces:

SourceFactory

public class DefaultSourceFactory
extends Object
implements SourceFactory

Field Summary

Map<String,Class<? extends Source>>

sourceRegistry

Constructor Summary

DefaultSourceFactory()

Method Summary

Source	create(String name)
Set<String>	getSourceNames()
Map<String,Class<? extends Source>>	getSourceRegistry()
boolean	register(String name, Class<? extends Source> sourceClass)
void	setSourceRegistry(Map<String,Class<? extends Source>> sourceRegistry)
String	toString()
boolean	unregister(String name)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

sourceRegistry

public Map<String,Class<? extends Source>> sourceRegistry

Constructor Detail

DefaultSourceFactory

public DefaultSourceFactory()

Method Detail

register

public boolean register(String name,
                        Class<? extends Source> sourceClass)

Specified by:

register in interface SourceFactory

unregister

public boolean unregister(String name)

Specified by:

unregister in interface SourceFactory

getSourceNames

public Set<String> getSourceNames()

Specified by:

getSourceNames in interface SourceFactory

create

public Source create(String name)
              throws InstantiationException

Specified by:

create in interface SourceFactory

Throws:

InstantiationException

toString

public String toString()

Overrides:

toString in class Object

getSourceRegistry

public Map<String,Class<? extends Source>> getSourceRegistry()

setSourceRegistry

public void setSourceRegistry(Map<String,Class<? extends Source>> sourceRegistry)