org.apache.flume.channel
Class MultiplexingChannelSelector

java.lang.Object
  extended by org.apache.flume.channel.AbstractChannelSelector
      extended by org.apache.flume.channel.MultiplexingChannelSelector
All Implemented Interfaces:
ChannelSelector, Configurable, NamedComponent

public class MultiplexingChannelSelector
extends AbstractChannelSelector


Field Summary
static String CONFIG_MULTIPLEX_HEADER_NAME
           
static String CONFIG_PREFIX_DEFAULT
           
static String CONFIG_PREFIX_MAPPING
           
static String DEFAULT_MULTIPLEX_HEADER
           
 
Constructor Summary
MultiplexingChannelSelector()
           
 
Method Summary
 void configure(Context context)
           
 List<Channel> getOptionalChannels(Event event)
          Returns a list of optional channels.
 List<Channel> getRequiredChannels(Event event)
          Returns a list of required channels.
 
Methods inherited from class org.apache.flume.channel.AbstractChannelSelector
getAllChannels, getName, setChannels, setName
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

CONFIG_MULTIPLEX_HEADER_NAME

public static final String CONFIG_MULTIPLEX_HEADER_NAME
See Also:
Constant Field Values

DEFAULT_MULTIPLEX_HEADER

public static final String DEFAULT_MULTIPLEX_HEADER
See Also:
Constant Field Values

CONFIG_PREFIX_MAPPING

public static final String CONFIG_PREFIX_MAPPING
See Also:
Constant Field Values

CONFIG_PREFIX_DEFAULT

public static final String CONFIG_PREFIX_DEFAULT
See Also:
Constant Field Values
Constructor Detail

MultiplexingChannelSelector

public MultiplexingChannelSelector()
Method Detail

getRequiredChannels

public List<Channel> getRequiredChannels(Event event)
Description copied from interface: ChannelSelector
Returns a list of required channels. A failure in writing the event to these channels must be communicated back to the source that received this event.

Returns:
the list of required channels that this selector has selected for the given event.

getOptionalChannels

public List<Channel> getOptionalChannels(Event event)
Description copied from interface: ChannelSelector
Returns a list of optional channels. A failure in writing the event to these channels must be ignored.

Returns:
the list of optional channels that this selector has selected for the given event.

configure

public void configure(Context context)


Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.