com.github.ddth.queue.impl.universal

Class UniversalKafkaQueue

java.lang.Object

com.github.ddth.queue.impl.KafkaQueue

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

com.github.ddth.queue.impl.universal.UniversalKafkaQueue

All Implemented Interfaces:

IQueue

public class UniversalKafkaQueue
extends BaseUniversalKafkaQueue<UniversalQueueMessage>

(Experimental) 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.

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

serialize, take

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

destroy, ephemeralSize, finish, getBufferSize, getConsumerGroupId, getKafkaClient, getOffsetCommitPeriodMs, getOrphanMessages, getProducerType, getTopicName, getZkConnString, init, isLeaderAutoRebalance, moveFromEphemeralToQueueStorage, putToQueue, queue, queueSize, requeue, requeueSilent, setBufferSize, setConsumerGroupId, setKafkaClient, setLeaderAutoRebalance, setOffsetCommitPeriodMs, setProducerType, setTopicName, setZkConnString, takeFromQueue

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

deserialize

protected UniversalQueueMessage deserialize(byte[] msgData)

Deserilizes a queue message.

Specified by:

deserialize in class KafkaQueue

Returns: