com.github.ddth.queue.impl

Class KafkaQueueFactory<T extends KafkaQueue>

java.lang.Object

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

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

All Implemented Interfaces:

IQueueFactory

Direct Known Subclasses:

UniversalKafkaQueueFactory, UniversalKafkaQueueFactory

public abstract class KafkaQueueFactory<T extends KafkaQueue>
extends AbstractQueueFactory<T>

Factory to create KafkaQueue instances.

Since:

0.4.1

Author:

Thanh Ba Nguyen

Field Summary

Fields

Modifier and Type	Field and Description
static String	SPEC_FIELD_BOOTSTRAP_SERVERS
static String	SPEC_FIELD_CONSUMER_GROUP_ID
static String	SPEC_FIELD_CONSUMER_PROPERTIES
static String	SPEC_FIELD_PRODUCER_PROPERTIES
static String	SPEC_FIELD_PRODUCER_TYPE
static String	SPEC_FIELD_TOPIC

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

queueInstances

Constructor Summary

Constructors

Constructor and Description
KafkaQueueFactory()

Method Summary

Modifier and Type	Method and Description
protected boolean	disposeQueue(T queue)
Properties	getDefaultConsumerProps()
Properties	getDefaultProducerProps()
com.github.ddth.kafka.KafkaClient.ProducerType	getDefaultProducerType()
protected void	initQueue(T queue, QueueSpec spec) Initializes a newly created queue instance.
void	setDefaultConsumerProps(Properties defaultConsumerProps)
void	setDefaultProducerProps(Properties defaultProducerProps)
void	setDefaultProducerType(com.github.ddth.kafka.KafkaClient.ProducerType defaultProducerType)

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

createAndInitQueue, createQueueInstance, destroy, disposeQueue, getQueue, init

Methods inherited from class java.lang.Object

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

Field Detail

SPEC_FIELD_CONSUMER_GROUP_ID

public static final String SPEC_FIELD_CONSUMER_GROUP_ID

See Also:

Constant Field Values

SPEC_FIELD_BOOTSTRAP_SERVERS

public static final String SPEC_FIELD_BOOTSTRAP_SERVERS

See Also:

Constant Field Values

SPEC_FIELD_TOPIC

public static final String SPEC_FIELD_TOPIC

See Also:

Constant Field Values

SPEC_FIELD_PRODUCER_TYPE

public static final String SPEC_FIELD_PRODUCER_TYPE

See Also:

Constant Field Values

SPEC_FIELD_PRODUCER_PROPERTIES

public static final String SPEC_FIELD_PRODUCER_PROPERTIES

See Also:

Constant Field Values

SPEC_FIELD_CONSUMER_PROPERTIES

public static final String SPEC_FIELD_CONSUMER_PROPERTIES

See Also:

Constant Field Values

Constructor Detail

KafkaQueueFactory

public KafkaQueueFactory()

Method Detail

getDefaultProducerType

public com.github.ddth.kafka.KafkaClient.ProducerType getDefaultProducerType()

setDefaultProducerType

public void setDefaultProducerType(com.github.ddth.kafka.KafkaClient.ProducerType defaultProducerType)

getDefaultProducerProps

public Properties getDefaultProducerProps()

setDefaultProducerProps

public void setDefaultProducerProps(Properties defaultProducerProps)

getDefaultConsumerProps

public Properties getDefaultConsumerProps()

setDefaultConsumerProps

public void setDefaultConsumerProps(Properties defaultConsumerProps)

initQueue

protected void initQueue(T queue,
                         QueueSpec spec)

Initializes a newly created queue instance.

Called by AbstractQueueFactory.createAndInitQueue(QueueSpec). Sub-class may override this method to implement its own business logic.

Overrides:

initQueue in class AbstractQueueFactory<T extends KafkaQueue>

disposeQueue

protected boolean disposeQueue(T queue)

Specified by:

disposeQueue in class AbstractQueueFactory<T extends KafkaQueue>