org.apache.qpid.server.store.berkeleydb

Class CoalescingCommiter

java.lang.Object

org.apache.qpid.server.store.berkeleydb.CoalescingCommiter

All Implemented Interfaces:

Committer

public class CoalescingCommiter
extends Object
implements Committer

Constructor Summary

Constructors

Constructor and Description
CoalescingCommiter(String name, EnvironmentFacade environmentFacade)

Method Summary

Modifier and Type	Method and Description
void	commit(com.sleepycat.je.Transaction tx, boolean syncCommit)
<X> com.google.common.util.concurrent.ListenableFuture<X>	commitAsync(com.sleepycat.je.Transaction tx, X val)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

CoalescingCommiter

public CoalescingCommiter(String name,
                          EnvironmentFacade environmentFacade)

Method Detail

start

public void start()

Specified by:

start in interface Committer

stop

public void stop()

Specified by:

stop in interface Committer

commit

public void commit(com.sleepycat.je.Transaction tx,
                   boolean syncCommit)

Specified by:

commit in interface Committer

commitAsync

public <X> com.google.common.util.concurrent.ListenableFuture<X> commitAsync(com.sleepycat.je.Transaction tx,
                                                                             X val)

Specified by:

commitAsync in interface Committer