public class UniversalKafkaQueue extends BaseUniversalKafkaQueue<UniversalQueueMessage>
IQueue.
Queue and Take UniversalQueueMessages.
Implementation: see KafkaQueue.
| Constructor and Description |
|---|
UniversalKafkaQueue() |
| Modifier and Type | Method and Description |
|---|---|
protected UniversalQueueMessage |
deserialize(byte[] msgData)
Deserilizes a queue message.
|
serialize, takedestroy, 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, takeFromQueueprotected UniversalQueueMessage deserialize(byte[] msgData)
deserialize in class KafkaQueueCopyright © 2015 DDTH. All Rights Reserved.