co.cask.cdap.data2.transaction.queue

Class NoopQueueConfigurer

java.lang.Object

co.cask.cdap.data2.transaction.queue.NoopQueueConfigurer

All Implemented Interfaces:

QueueConfigurer, co.cask.tephra.TransactionAware, Closeable, AutoCloseable

public final class NoopQueueConfigurer
extends Object
implements QueueConfigurer

A QueueConfigurer that does nothing.

Constructor Summary

Constructors

Constructor and Description
NoopQueueConfigurer()

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
boolean	commitTx()
void	configureGroups(Iterable<? extends ConsumerGroupConfig> groupConfigs) Changes the configuration of all consumer groups.
void	configureInstances(long groupId, int instances) Changes the number of consumer instances of the given consumer group.
String	getTransactionAwareName()
Collection<byte[]>	getTxChanges()
void	postTxCommit()
boolean	rollbackTx()
void	startTx(co.cask.tephra.Transaction tx)
void	updateTx(co.cask.tephra.Transaction tx)

Methods inherited from class java.lang.Object

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

Constructor Detail

NoopQueueConfigurer

public NoopQueueConfigurer()

Method Detail

configureInstances

public void configureInstances(long groupId,
                      int instances)
                        throws Exception

Description copied from interface: QueueConfigurer

Changes the number of consumer instances of the given consumer group. The consumer group configuration needs to be existed already.

Specified by:

configureInstances in interface QueueConfigurer

Parameters:

groupId - groupId of the consumer group

instances - number of instances to change to

Throws:

Exception - if failed to change number of instances.

configureGroups

public void configureGroups(Iterable<? extends ConsumerGroupConfig> groupConfigs)
                     throws Exception

Description copied from interface: QueueConfigurer

Changes the configuration of all consumer groups.

Specified by:

configureGroups in interface QueueConfigurer

Parameters:

groupConfigs - information for all consumer groups

Throws:

Exception - if failed to change consumer group configuration

startTx

public void startTx(co.cask.tephra.Transaction tx)

Specified by:

startTx in interface co.cask.tephra.TransactionAware

updateTx

public void updateTx(co.cask.tephra.Transaction tx)

Specified by:

updateTx in interface co.cask.tephra.TransactionAware

getTxChanges

public Collection<byte[]> getTxChanges()

Specified by:

getTxChanges in interface co.cask.tephra.TransactionAware

commitTx

public boolean commitTx()
                 throws Exception

Specified by:

commitTx in interface co.cask.tephra.TransactionAware

Throws:

Exception

postTxCommit

public void postTxCommit()

Specified by:

postTxCommit in interface co.cask.tephra.TransactionAware

rollbackTx

public boolean rollbackTx()
                   throws Exception

Specified by:

rollbackTx in interface co.cask.tephra.TransactionAware

Throws:

Exception

getTransactionAwareName

public String getTransactionAwareName()

Specified by:

getTransactionAwareName in interface co.cask.tephra.TransactionAware

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException