org.apache.flume.channel
Class MemoryChannel

java.lang.Object
  org.apache.flume.channel.AbstractChannel
      org.apache.flume.channel.BasicChannelSemantics
          org.apache.flume.channel.MemoryChannel

All Implemented Interfaces:

Channel, Configurable, LifecycleAware, NamedComponent

public class MemoryChannel
extends BasicChannelSemantics

Nested Class Summary

class

MemoryChannel.MemoryTransaction

Constructor Summary

MemoryChannel()

Method Summary

void	configure(Context context)
protected BasicTransactionSemantics	createTransaction() Called to create new Transaction objects, which must extend BasicTransactionSemantics.

Methods inherited from class org.apache.flume.channel.BasicChannelSemantics

getTransaction, initialize, put, take

Methods inherited from class org.apache.flume.channel.AbstractChannel

getLifecycleState, getName, setName, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

MemoryChannel

public MemoryChannel()

Method Detail

configure

public void configure(Context context)

Specified by:

configure in interface Configurable

Overrides:

configure in class AbstractChannel

createTransaction

protected BasicTransactionSemantics createTransaction()

Description copied from class: BasicChannelSemantics

Called to create new Transaction objects, which must extend BasicTransactionSemantics. Each object is used for only one transaction, but is stored in a thread-local and retrieved by getTransaction for the duration of that transaction.

Specified by:

createTransaction in class BasicChannelSemantics