org.apache.flume.channel
Class DefaultChannelFactory

java.lang.Object
  org.apache.flume.channel.DefaultChannelFactory

All Implemented Interfaces:

ChannelFactory

public class DefaultChannelFactory
extends Object
implements ChannelFactory

Constructor Summary

DefaultChannelFactory()

Method Summary

Channel	create(String name)
Channel	createFanout(String chList, Map<String,Channel> chMap)
Set<String>	getChannelNames()
Map<String,Class<? extends Channel>>	getChannelRegistry()
boolean	register(String name, Class<? extends Channel> channelClass)
void	setChannelRegistry(Map<String,Class<? extends Channel>> channelRegistry)
String	toString()
boolean	unregister(String name)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultChannelFactory

public DefaultChannelFactory()

Method Detail

register

public boolean register(String name,
                        Class<? extends Channel> channelClass)

Specified by:

register in interface ChannelFactory

unregister

public boolean unregister(String name)

Specified by:

unregister in interface ChannelFactory

getChannelNames

public Set<String> getChannelNames()

Specified by:

getChannelNames in interface ChannelFactory

create

public Channel create(String name)
               throws InstantiationException

Specified by:

create in interface ChannelFactory

Throws:

InstantiationException

toString

public String toString()

Overrides:

toString in class Object

getChannelRegistry

public Map<String,Class<? extends Channel>> getChannelRegistry()

setChannelRegistry

public void setChannelRegistry(Map<String,Class<? extends Channel>> channelRegistry)

createFanout

public Channel createFanout(String chList,
                            Map<String,Channel> chMap)
                     throws InstantiationException

Specified by:

createFanout in interface ChannelFactory

Throws:

InstantiationException