co.cask.cdap.data2.transaction.queue.leveldb

Class LevelDBQueueClientFactory

java.lang.Object

co.cask.cdap.data2.transaction.queue.leveldb.LevelDBQueueClientFactory

All Implemented Interfaces:

QueueClientFactory

public final class LevelDBQueueClientFactory
extends Object
implements QueueClientFactory

Factory for LevelDB queue clients.

Constructor Summary

Constructors

Constructor and Description
LevelDBQueueClientFactory(CConfiguration cConf, LevelDBTableService service, LevelDBQueueAdmin queueAdmin)

Method Summary

Methods

Modifier and Type	Method and Description
QueueConsumer	createConsumer(QueueName queueName, ConsumerConfig consumerConfig, int numGroups)
QueueProducer	createProducer(QueueName queueName)
QueueProducer	createProducer(QueueName queueName, QueueMetrics queueMetrics)

Methods inherited from class java.lang.Object

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

Constructor Detail

LevelDBQueueClientFactory

@Inject
public LevelDBQueueClientFactory(CConfiguration cConf,
                                LevelDBTableService service,
                                LevelDBQueueAdmin queueAdmin)
                          throws Exception

Throws:

Exception

Method Detail

createProducer

public QueueProducer createProducer(QueueName queueName)
                             throws IOException

Specified by:

createProducer in interface QueueClientFactory

Throws:

IOException

createProducer

public QueueProducer createProducer(QueueName queueName,
                           QueueMetrics queueMetrics)
                             throws IOException

Specified by:

createProducer in interface QueueClientFactory

Throws:

IOException

createConsumer

public QueueConsumer createConsumer(QueueName queueName,
                           ConsumerConfig consumerConfig,
                           int numGroups)
                             throws IOException

Specified by:

createConsumer in interface QueueClientFactory

Throws:

IOException