|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.xmlBlaster.util.queuemsg.MsgQueueEntry org.xmlBlaster.client.queuemsg.MsgQueueEraseEntry
public final class MsgQueueEraseEntry
Wraps an erase() message into an entry for a sorted queue.
Field Summary | |
---|---|
private EraseKey |
eraseKey
|
private EraseQos |
eraseQos
|
private long |
immutableSizeInBytes
|
private SessionName |
receiver
|
private static long |
serialVersionUID
|
Fields inherited from class org.xmlBlaster.util.queuemsg.MsgQueueEntry |
---|
entryType, glob, persistent, priority, redeliverCounter, refToCloneOrigin, returnObj, storageId, uniqueIdString, uniqueIdTimestamp, wantReturnObj |
Constructor Summary | |
---|---|
MsgQueueEraseEntry(Global glob,
PriorityEnum priority,
StorageId storageId,
Timestamp timestamp,
long sizeInBytes,
EraseKey eraseKey,
EraseQos eraseQos)
For persistence recovery |
|
MsgQueueEraseEntry(Global glob,
StorageId storageId,
EraseKey eraseKey,
EraseQos eraseQos)
Use this constructor if a new message object is fed by method erase(). |
Method Summary | |
---|---|
java.lang.Object |
clone()
Returns a shallow clone |
void |
embeddedObjectToXml(java.io.OutputStream out,
java.util.Properties props)
Dump content to xml representation |
java.lang.Object |
getEmbeddedObject()
The embeddded object for this implementing class is an Object[2] where Object[0] = qos.toXml() Object[1] = key.toXml() |
EraseKey |
getEraseKey()
|
EraseQos |
getEraseQos()
|
java.lang.String |
getKeyOid()
|
MsgUnit |
getMsgUnit()
|
Timestamp |
getRcvTimestamp()
return null |
SessionName |
getReceiver()
|
SessionName |
getSender()
Access the unique login name of the eraser. |
long |
getSizeInBytes()
Try to find out the approximate memory consumption of this message in RAM. |
boolean |
isDestroyed()
Flag which marks the entry as destroyed, you should take it from queue and ignore/discard it |
boolean |
isExpired()
Flag which marks the entry as outdated |
boolean |
isInternal()
|
void |
setReceiver(SessionName receiver)
|
Methods inherited from class org.xmlBlaster.util.queuemsg.MsgQueueEntry |
---|
added, compare, equals, finalize, getEmbeddedType, getLogId, getMeat, getMethodName, getPriority, getPriorityEnum, getRedeliverCounter, getRef, getReturnObj, getStorageId, getUniqueId, getUniqueIdLong, incrRedeliverCounter, isPersistent, isStored, removed, setGlobal, setPersistent, setReturnObj, setStored, setWantReturnObject, toString, toXml, toXml, wantReturnObj |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
private static final long serialVersionUID
private final EraseQos eraseQos
private final EraseKey eraseKey
private SessionName receiver
private final long immutableSizeInBytes
Constructor Detail |
---|
public MsgQueueEraseEntry(Global glob, StorageId storageId, EraseKey eraseKey, EraseQos eraseQos) throws XmlBlasterException
XmlBlasterException
public MsgQueueEraseEntry(Global glob, PriorityEnum priority, StorageId storageId, Timestamp timestamp, long sizeInBytes, EraseKey eraseKey, EraseQos eraseQos)
Method Detail |
---|
public boolean isExpired()
MsgQueueEntry
isExpired
in class MsgQueueEntry
MsgQueueEntry.isExpired()
public boolean isDestroyed()
MsgQueueEntry
isDestroyed
in class MsgQueueEntry
MsgQueueEntry.isDestroyed()
public EraseQos getEraseQos()
public EraseKey getEraseKey()
public MsgUnit getMsgUnit()
getMsgUnit
in class MsgQueueEntry
public SessionName getSender()
getSender
in class MsgQueueEntry
MsgQueueEntry.getSender()
public void setReceiver(SessionName receiver)
MsgQueueEntry.getReceiver()
public SessionName getReceiver()
getReceiver
in class MsgQueueEntry
MsgQueueEntry.getReceiver()
public java.lang.String getKeyOid()
getKeyOid
in class MsgQueueEntry
MsgQueueEntry.getKeyOid()
public Timestamp getRcvTimestamp()
public java.lang.Object getEmbeddedObject()
public long getSizeInBytes()
MsgQueueEntry
getSizeInBytes
in interface I_Entry
getSizeInBytes
in class MsgQueueEntry
public boolean isInternal()
isInternal
in class MsgQueueEntry
public final void embeddedObjectToXml(java.io.OutputStream out, java.util.Properties props) throws java.io.IOException
I_Entry
out
- The stream to dump toprops
- Control porperties
java.io.IOException
public java.lang.Object clone()
clone
in class MsgQueueEntry
|
xmlBlaster 2.2.0 API | |||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |