co.cask.cdap.data2.transaction.queue.inmemory

Class InMemoryQueueClientFactory

java.lang.Object

co.cask.cdap.data2.transaction.queue.inmemory.InMemoryQueueClientFactory

All Implemented Interfaces:

QueueClientFactory

public class InMemoryQueueClientFactory
extends Object
implements QueueClientFactory

Constructor Summary

Constructors

Constructor and Description
InMemoryQueueClientFactory(InMemoryQueueService queueService)

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

InMemoryQueueClientFactory

@Inject
public InMemoryQueueClientFactory(InMemoryQueueService queueService)

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