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, Closeable, AutoCloseable

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

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

putToQueue, serialize, take

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

close, 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

UniversalKafkaQueue

public UniversalKafkaQueue()

Method Detail

deserialize

protected UniversalQueueMessage deserialize(byte[] msgData)

Deserilizes a queue message.

Specified by:

deserialize in class KafkaQueue

Returns: