com.github.ddth.queue.impl.universal

Class UniversalKafkaQueueFactory

java.lang.Object

com.github.ddth.queue.impl.AbstractQueueFactory<T>

com.github.ddth.queue.impl.KafkaQueueFactory<UniversalKafkaQueue>

com.github.ddth.queue.impl.universal.UniversalKafkaQueueFactory

All Implemented Interfaces:

IQueueFactory

public class UniversalKafkaQueueFactory
extends KafkaQueueFactory<UniversalKafkaQueue>

Factory to create UniversalKafkaQueue instances.

Since:

0.4.1

Author:

Thanh Ba Nguyen

Field Summary

Fields inherited from class com.github.ddth.queue.impl.KafkaQueueFactory

SPEC_FIELD_BOOTSTRAP_SERVERS, SPEC_FIELD_CONSUMER_GROUP_ID, SPEC_FIELD_CONSUMER_PROPERTIES, SPEC_FIELD_PRODUCER_PROPERTIES, SPEC_FIELD_PRODUCER_TYPE, SPEC_FIELD_TOPIC

Fields inherited from class com.github.ddth.queue.impl.AbstractQueueFactory

queueInstances

Constructor Summary

Constructors

Constructor and Description
UniversalKafkaQueueFactory()

Method Summary

Modifier and Type	Method and Description
protected UniversalKafkaQueue	createQueueInstance(QueueSpec spec) Creates a new queue instance.

Methods inherited from class com.github.ddth.queue.impl.KafkaQueueFactory

disposeQueue, getDefaultConsumerProps, getDefaultProducerProps, getDefaultProducerType, initQueue, setDefaultConsumerProps, setDefaultProducerProps, setDefaultProducerType

Methods inherited from class com.github.ddth.queue.impl.AbstractQueueFactory

createAndInitQueue, destroy, disposeQueue, getQueue, init

Methods inherited from class java.lang.Object

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

Constructor Detail

UniversalKafkaQueueFactory

public UniversalKafkaQueueFactory()

Method Detail

createQueueInstance

protected UniversalKafkaQueue createQueueInstance(QueueSpec spec)

Creates a new queue instance.

Called by AbstractQueueFactory.createAndInitQueue(QueueSpec). Sub-class is to implement this method.

Specified by:

createQueueInstance in class AbstractQueueFactory<UniversalKafkaQueue>

Returns: