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

Class LevelDBAndInMemoryQueueClientFactory

java.lang.Object

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

All Implemented Interfaces:

QueueClientFactory

public final class LevelDBAndInMemoryQueueClientFactory
extends Object
implements QueueClientFactory

Factory for LevelDB queue clients.

Constructor Summary

Constructors

Constructor and Description
LevelDBAndInMemoryQueueClientFactory(InMemoryQueueClientFactory inMemoryFactory, LevelDBQueueClientFactory levelDBFactory)

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

LevelDBAndInMemoryQueueClientFactory

@Inject
public LevelDBAndInMemoryQueueClientFactory(InMemoryQueueClientFactory inMemoryFactory,
                                           LevelDBQueueClientFactory levelDBFactory)

Method Detail

createProducer

public QueueProducer createProducer(QueueName queueName)
                             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

createProducer

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

Specified by:

createProducer in interface QueueClientFactory

Throws:

IOException