com.eurotech.framework.core.data
Class DataMessage

java.lang.Object
  extended by com.eurotech.framework.core.data.DataMessage

public class DataMessage
extends Object

DataMessage is a message that is currently transiting through the DataService. It is a wrapper class over the message payload as produced by the client application but it also capture all the state information of the message through its DataService life-cycle of: stored -> published -> confirmed.


Nested Class Summary
static class DataMessage.Builder
           
 
Constructor Summary
DataMessage()
           
DataMessage(DataMessage.Builder b)
           
 
Method Summary
 Date droppedOn()
           
 Date getConfirmedOn()
           
 Date getCreatedOn()
           
 int getId()
           
 byte[] getPayload()
           
 int getPriority()
           
 int getPublishedMessageId()
           
 Date getPublishedOn()
           
 int getQos()
           
 String getSessionId()
           
 String getTopic()
           
 boolean isRetain()
           
 void setPublishedMessageId(int publishedMessageId)
           
 String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

DataMessage

public DataMessage()

DataMessage

public DataMessage(DataMessage.Builder b)
Method Detail

getId

public int getId()

getTopic

public String getTopic()

getQos

public int getQos()

isRetain

public boolean isRetain()

getCreatedOn

public Date getCreatedOn()

getPublishedOn

public Date getPublishedOn()

getPublishedMessageId

public int getPublishedMessageId()

setPublishedMessageId

public void setPublishedMessageId(int publishedMessageId)

getConfirmedOn

public Date getConfirmedOn()

getPayload

public byte[] getPayload()

getPriority

public int getPriority()

getSessionId

public String getSessionId()

droppedOn

public Date droppedOn()

toString

public String toString()
Overrides:
toString in class Object


Copyright © 2013. All Rights Reserved.