com.github.ddth.queue.impl

Class UniversalKafkaQueue

java.lang.Object

com.github.ddth.queue.impl.KafkaQueue

com.github.ddth.queue.impl.UniversalKafkaQueue

All Implemented Interfaces:

IQueue

public class UniversalKafkaQueue
extends KafkaQueue

Universal Kafka implementation of IQueue.

Queue and Take UniversalQueueMessages.

Implementation: see KafkaQueue.

Since:

0.3.2

Author:

Thanh Ba Nguyen

Constructor Summary

Constructors

Constructor and Description
UniversalKafkaQueue()

Method Summary

Methods

Modifier and Type	Method and Description
protected UniversalQueueMessage	deserialize(byte[] msgData) Deserilizes a queue message.
protected byte[]	serialize(IQueueMessage _msg) Serializes a queue message to store in Kafka.
UniversalQueueMessage	take() Takes a message out of queue.

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

destroy, ephemeralSize, finish, getKafkaClient, getOrphanMessages, getProducerType, getTopicName, getZkConnString, init, moveFromEphemeralToQueueStorage, putToQueue, queue, queueSize, requeue, requeueSilent, setKafkaClient, setProducerType, setTopicName, setZkConnString

Methods inherited from class java.lang.Object

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

Constructor Detail

UniversalKafkaQueue

public UniversalKafkaQueue()

Method Detail

serialize

protected byte[] serialize(IQueueMessage _msg)

Serializes a queue message to store in Kafka.

Specified by:

serialize in class KafkaQueue

Returns:

deserialize

protected UniversalQueueMessage deserialize(byte[] msgData)

Deserilizes a queue message.

Specified by:

deserialize in class KafkaQueue

Returns:

take

public UniversalQueueMessage 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: