com.github.ddth.queue.impl

Class BaseUniversalKafkaQueue<T extends BaseUniversalQueueMessage>

java.lang.Object

com.github.ddth.queue.impl.KafkaQueue

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

Type Parameters:

T -

All Implemented Interfaces:

IQueue, Closeable, AutoCloseable

Direct Known Subclasses:

UniversalKafkaQueue, UniversalKafkaQueue

public abstract class BaseUniversalKafkaQueue<T extends BaseUniversalQueueMessage>
extends KafkaQueue

Base class for universal Kafka queue implementations.

Since:

0.3.3

Author:

Thanh Nguyen

Constructor Summary

Constructors

Constructor and Description
BaseUniversalKafkaQueue()

Method Summary

Modifier and Type	Method and Description
protected boolean	putToQueue(IQueueMessage msg) Puts a message to Kafka queue, partitioning message by BaseUniversalQueueMessage.partitionKey() (or IQueueMessage.qId() if message is not of type BaseUniversalQueueMessage)).
protected byte[]	serialize(IQueueMessage _msg) Serializes a queue message to store in Kafka.
T	take() Takes a message out of queue.

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

close, deserialize, destroy, ephemeralSize, finish, getConsumerGroupId, getKafkaBootstrapServers, getKafkaClient, getKafkaConsumerProperties, getKafkaProducerProperties, getOrphanMessages, getProducerType, getTopicName, init, moveFromEphemeralToQueueStorage, queue, queueSize, requeue, requeueSilent, setConsumerGroupId, setKafkaBootstrapServers, setKafkaClient, setKafkaConsumerProperties, setKafkaProducerProperties, setProducerType, setTopicName, takeFromQueue

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseUniversalKafkaQueue

public BaseUniversalKafkaQueue()

Method Detail

putToQueue

protected boolean putToQueue(IQueueMessage msg)

Puts a message to Kafka queue, partitioning message by BaseUniversalQueueMessage.partitionKey() (or IQueueMessage.qId() if message is not of type BaseUniversalQueueMessage)).

Overrides:

putToQueue in class KafkaQueue

Parameters:

msg -

Returns:

Since:

0.3.3.2

serialize

protected byte[] serialize(IQueueMessage _msg)
                    throws QueueException

Serializes a queue message to store in Kafka.

Specified by:

serialize in class KafkaQueue

Returns:

Throws:

QueueException

take

public T take()

Takes a message out of queue.

Implementation flow:

• Read message from head of queue storage.
• Write message to ephemeral storage.
• Remove message from queue storage.

Note: ephemeral storage implementation is optional, depends on implementation.

Specified by:

take in interface IQueue

Overrides:

take in class KafkaQueue

Returns: