org.xmlBlaster.client.queuemsg
Class MsgQueueUnSubscribeEntry

java.lang.Object
  org.xmlBlaster.util.queuemsg.MsgQueueEntry
      org.xmlBlaster.client.queuemsg.MsgQueueUnSubscribeEntry

All Implemented Interfaces:

java.lang.Cloneable, I_Entry, I_QueueEntry, java.io.Serializable

public final class MsgQueueUnSubscribeEntry

extends MsgQueueEntry

Wraps an unSubscribe() message into an entry for a sorted queue.

Author:

xmlBlaster@marcelruff.info

See Also:

Serialized Form

Field Summary

private long	immutableSizeInBytes
private static java.lang.String	ME
private SessionName	receiver
private static long	serialVersionUID
private UnSubscribeKey	unSubscribeKey
private UnSubscribeQos	unSubscribeQos

Fields inherited from class org.xmlBlaster.util.queuemsg.MsgQueueEntry

entryType, glob, persistent, priority, redeliverCounter, refToCloneOrigin, returnObj, storageId, uniqueIdString, uniqueIdTimestamp, wantReturnObj

Constructor Summary

MsgQueueUnSubscribeEntry(Global glob, PriorityEnum priority, StorageId storageId, Timestamp timestamp, long sizeInBytes, UnSubscribeKey unSubscribeKey, UnSubscribeQos unSubscribeQos)
For persistence recovery

MsgQueueUnSubscribeEntry(Global glob, StorageId storageId, UnSubscribeKey unSubscribeKey, UnSubscribeQos unSubscribeQos)
Use this constructor if a new message object is fed by method unSubscribe().

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()
java.lang.String	getKeyOid()
Timestamp	getRcvTimestamp() return null
SessionName	getReceiver()
SessionName	getSender() Access the unique login name of the unSubscriber.
long	getSizeInBytes() Try to find out the approximate memory consumption of this message in RAM.
UnSubscribeKey	getUnSubscribeKey()
UnSubscribeQos	getUnSubscribeQos()
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, getMethodName, getMsgUnit, getPriority, getPriorityEnum, getRedeliverCounter, 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

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

ME

private static final java.lang.String ME

See Also:

Constant Field Values

unSubscribeQos

private final UnSubscribeQos unSubscribeQos

unSubscribeKey

private final UnSubscribeKey unSubscribeKey

receiver

private SessionName receiver

immutableSizeInBytes

private final long immutableSizeInBytes

Constructor Detail

MsgQueueUnSubscribeEntry

public MsgQueueUnSubscribeEntry(Global glob,
                                StorageId storageId,
                                UnSubscribeKey unSubscribeKey,
                                UnSubscribeQos unSubscribeQos)
                         throws XmlBlasterException

Use this constructor if a new message object is fed by method unSubscribe().

Parameters:

unSubscribeQos -

MsgQueueUnSubscribeEntry

public MsgQueueUnSubscribeEntry(Global glob,
                                PriorityEnum priority,
                                StorageId storageId,
                                Timestamp timestamp,
                                long sizeInBytes,
                                UnSubscribeKey unSubscribeKey,
                                UnSubscribeQos unSubscribeQos)

For persistence recovery

Method Detail

isExpired

public boolean isExpired()

Description copied from class: MsgQueueEntry

Flag which marks the entry as outdated

Specified by:

isExpired in class MsgQueueEntry

See Also:

MsgQueueEntry.isExpired()

isDestroyed

public boolean isDestroyed()

Description copied from class: MsgQueueEntry

Flag which marks the entry as destroyed, you should take it from queue and ignore/discard it

Specified by:

isDestroyed in class MsgQueueEntry

See Also:

MsgQueueEntry.isDestroyed()

getUnSubscribeQos

public UnSubscribeQos getUnSubscribeQos()

getUnSubscribeKey

public UnSubscribeKey getUnSubscribeKey()

getSender

public SessionName getSender()

Access the unique login name of the unSubscriber.

Specified by:

getSender in class MsgQueueEntry

Returns:

loginName of the source

See Also:

MsgQueueEntry.getSender()

setReceiver

public void setReceiver(SessionName receiver)

Returns:

The name of the receiver (data sink) or null

See Also:

MsgQueueEntry.getReceiver()

getReceiver

public SessionName getReceiver()

Specified by:

getReceiver in class MsgQueueEntry

Returns:

The name of the receiver (data sink) or null

See Also:

MsgQueueEntry.getReceiver()

getKeyOid

public java.lang.String getKeyOid()

Specified by:

getKeyOid in class MsgQueueEntry

Returns:

The message key oid or null

See Also:

MsgQueueEntry.getKeyOid()

getRcvTimestamp

public Timestamp getRcvTimestamp()

return null

getEmbeddedObject

public java.lang.Object getEmbeddedObject()

The embeddded object for this implementing class is an Object[2] where Object[0] = qos.toXml() Object[1] = key.toXml()

getSizeInBytes

public long getSizeInBytes()

Description copied from class: MsgQueueEntry

Try to find out the approximate memory consumption of this message in RAM.

NOTE: The derived classes need to add their data amount to this value.

Specified by:

getSizeInBytes in interface I_Entry

Overrides:

getSizeInBytes in class MsgQueueEntry

Returns:

the approximate size in bytes of this object which contributes to a QueueEntry memory consumption

isInternal

public boolean isInternal()

Specified by:

isInternal in class MsgQueueEntry

Returns:

true

embeddedObjectToXml

public final void embeddedObjectToXml(java.io.OutputStream out,
                                      java.util.Properties props)
                               throws java.io.IOException

Description copied from interface: I_Entry

Dump content to xml representation

Parameters:

out - The stream to dump to

props - Control porperties

Throws:

java.io.IOException

clone

public java.lang.Object clone()

Returns a shallow clone

Overrides:

clone in class MsgQueueEntry