Uses of Class
org.apache.flume.ChannelException

Packages that use ChannelException
org.apache.flume   
org.apache.flume.channel   
org.apache.flume.channel.jdbc   
 

Uses of ChannelException in org.apache.flume
 

Methods in org.apache.flume that throw ChannelException
 void Channel.put(Event event)
          Puts the given event into the channel.
 Event Channel.take()
          Returns the next event from the channel if available.
 

Uses of ChannelException in org.apache.flume.channel
 

Methods in org.apache.flume.channel that throw ChannelException
static void ChannelUtils.put(Channel channel, Collection<Event> events)
           A convenience method for multiple-event put transactions.
static void ChannelUtils.put(Channel channel, Event event)
           A convenience method for single-event put transactions.
 void BasicChannelSemantics.put(Event event)
           Ensures that a transaction exists for this thread and then delegates the put to the thread's BasicTransactionSemantics instance.
 Event BasicChannelSemantics.take()
           Ensures that a transaction exists for this thread and then delegates the take to the thread's BasicTransactionSemantics instance.
static Event ChannelUtils.take(Channel channel)
           A convenience method for single-event take transactions.
static List<Event> ChannelUtils.take(Channel channel, int max)
           A convenience method for multiple-event take transactions.
static
<T> T
ChannelUtils.transact(Channel channel, Callable<T> transactor)
           A general optimistic implementation of Transaction client semantics.
static void ChannelUtils.transact(Channel channel, Runnable transactor)
           A convenience method for transactions that don't require a return value.
 

Uses of ChannelException in org.apache.flume.channel.jdbc
 

Subclasses of ChannelException in org.apache.flume.channel.jdbc
 class JdbcChannelException
           
 

Methods in org.apache.flume.channel.jdbc that throw ChannelException
 void JdbcChannel.put(Event event)
           
 Event JdbcChannel.take()
           
 



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