org.apache.flume.channel
Class MemoryChannel.MemoryTransaction

java.lang.Object
  org.apache.flume.channel.BasicTransactionSemantics
      org.apache.flume.channel.MemoryChannel.MemoryTransaction

All Implemented Interfaces:

Transaction

Enclosing class:

MemoryChannel

public class MemoryChannel.MemoryTransaction
extends BasicTransactionSemantics

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flume.channel.BasicTransactionSemantics

BasicTransactionSemantics.State

Nested classes/interfaces inherited from interface org.apache.flume.Transaction

Transaction.TransactionState

Constructor Summary

MemoryChannel.MemoryTransaction(int transCapacity, ChannelCounter counter)

Method Summary

protected void	doCommit()
protected void	doPut(Event event)
protected void	doRollback()
protected Event	doTake()

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

begin, close, commit, doBegin, doClose, getState, put, rollback, take, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

MemoryChannel.MemoryTransaction

public MemoryChannel.MemoryTransaction(int transCapacity,
                                       ChannelCounter counter)

Method Detail

doPut

protected void doPut(Event event)

Specified by:

doPut in class BasicTransactionSemantics

doTake

protected Event doTake()
                throws InterruptedException

Specified by:

doTake in class BasicTransactionSemantics

Throws:

InterruptedException

doCommit

protected void doCommit()
                 throws InterruptedException

Specified by:

doCommit in class BasicTransactionSemantics

Throws:

InterruptedException

doRollback

protected void doRollback()

Specified by:

doRollback in class BasicTransactionSemantics