Uses of Class
com.github.ddth.queue.utils.QueueException

Packages that use QueueException

Package	Description
com.github.ddth.queue.impl
com.github.ddth.queue.utils

Uses of QueueException in com.github.ddth.queue.impl

Methods in com.github.ddth.queue.impl that throw QueueException

Modifier and Type	Method and Description
protected abstract IQueueMessage	KafkaQueue.deserialize(byte[] msgData) Deserilizes a queue message.
protected abstract byte[]	KafkaQueue.serialize(IQueueMessage msg) Serializes a queue message to store in Kafka.
protected byte[]	BaseUniversalRedisQueue.serialize(IQueueMessage _msg) Serializes a queue message to store in Redis.
protected byte[]	BaseUniversalKafkaQueue.serialize(IQueueMessage _msg) Serializes a queue message to store in Kafka.

Uses of QueueException in com.github.ddth.queue.utils

Subclasses of QueueException in com.github.ddth.queue.utils

Modifier and Type	Class and Description
static class	QueueException.CannotDeserializeQueueMessage Thrown to indicate that the queue message can not be deserialized.
static class	QueueException.CannotSerializeQueueMessage Thrown to indicate that the queue message can not be serialized.