com.github.ddth.queue.impl.universal2

Class UniversalQueueMessage

java.lang.Object

com.github.ddth.dao.BaseBo

com.github.ddth.queue.impl.BaseUniversalQueueMessage

com.github.ddth.queue.impl.universal2.UniversalQueueMessage

All Implemented Interfaces:

IQueueMessage

public class UniversalQueueMessage
extends BaseUniversalQueueMessage

Extended from BaseUniversalQueueMessage where queue_id is a String.

Since:

0.3.3

Author:

Thanh Ba Nguyen

Nested Class Summary

Nested classes/interfaces inherited from interface com.github.ddth.queue.IQueueMessage

IQueueMessage.EmptyQueueMessage

Field Summary

Fields inherited from class com.github.ddth.queue.impl.BaseUniversalQueueMessage

FIELD_CONTENT, FIELD_NUM_REQUEUES, FIELD_ORG_TIMESTAMP, FIELD_QUEUE_ID, FIELD_TIMESTAMP

Constructor Summary

Constructors

Constructor and Description
UniversalQueueMessage()

Method Summary

Methods

Modifier and Type	Method and Description
static UniversalQueueMessage	fromBytes(byte[] msgData) Deserializes from a byte[].
static void	main(String[] args)
static UniversalQueueMessage	newInstance() Creates a new UniversalQueueMessage object.
String	qId() Message's unique id in queue.
UniversalQueueMessage	qId(Object queueId) Sets message's unique queue id.

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

content, content, content, contentAsString, fromBytes, fromJson, qIncNumRequeues, qNumRequeues, qNumRequeues, qOriginalTimestamp, qOriginalTimestamp, qTimestamp, qTimestamp, toBytes

Methods inherited from class com.github.ddth.dao.BaseBo

equals, fromMap, getAttribute, getAttribute, hashCode, isDirty, markClean, markDirty, newObjectFromJson, setAttribute, toJson, toMap, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

UniversalQueueMessage

public UniversalQueueMessage()

Method Detail

newInstance

public static UniversalQueueMessage newInstance()

Creates a new UniversalQueueMessage object.

Returns:

qId

public String qId()

Message's unique id in queue.

Returns:

qId

public UniversalQueueMessage qId(Object queueId)

Sets message's unique queue id.

Returns:

fromBytes

public static UniversalQueueMessage fromBytes(byte[] msgData)

Deserializes from a byte[].

Parameters:

msgData -

Returns:

main

public static void main(String[] args)