co.cask.cdap.data2.queue

Interface QueueClientFactory

All Known Implementing Classes:

HBaseQueueClientFactory, InMemoryQueueClientFactory, LevelDBAndInMemoryQueueClientFactory, LevelDBQueueClientFactory

public interface QueueClientFactory

Factory for creating QueueProducer and QueueConsumer for different queue.

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)

Method Detail

createProducer

QueueProducer createProducer(QueueName queueName)
                             throws IOException

Throws:

IOException

createProducer

QueueProducer createProducer(QueueName queueName,
                           QueueMetrics queueMetrics)
                             throws IOException

Throws:

IOException

createConsumer

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

Throws:

IOException