org.apache.qpid.server.message

Class AbstractServerMessageImpl<X extends AbstractServerMessageImpl<X,T>,T extends StorableMessageMetaData>

java.lang.Object

org.apache.qpid.server.message.AbstractServerMessageImpl<X,T>

All Implemented Interfaces:

EnqueueableMessage, MessageContentSource, ServerMessage<T>

Direct Known Subclasses:

AMQMessage, InternalMessage, Message_1_0, MessageTransferMessage

public abstract class AbstractServerMessageImpl<X extends AbstractServerMessageImpl<X,T>,T extends StorableMessageMetaData>
extends Object
implements ServerMessage<T>

Constructor Summary

Constructors

Constructor and Description
AbstractServerMessageImpl(StoredMessage<T> handle, Object connectionReference)

Method Summary

Modifier and Type	Method and Description
String	debugIdentity()
Object	getConnectionReference()
Collection<QpidByteBuffer>	getContent()
int	getContent(ByteBuffer buf)
long	getMessageNumber()
StoredMessage<T>	getStoredMessage()
boolean	isPersistent()
boolean	isReferenced()
boolean	isReferenced(TransactionLogResource resource)
MessageReference<X>	newReference()
MessageReference<X>	newReference(TransactionLogResource object)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.qpid.server.message.ServerMessage

getArrivalTime, getExpiration, getInitialRoutingAddress, getMessageHeader, getSize

Constructor Detail

AbstractServerMessageImpl

public AbstractServerMessageImpl(StoredMessage<T> handle,
                                 Object connectionReference)

Method Detail

getStoredMessage

public StoredMessage<T> getStoredMessage()

Specified by:

getStoredMessage in interface EnqueueableMessage

Specified by:

getStoredMessage in interface ServerMessage<T extends StorableMessageMetaData>

debugIdentity

public String debugIdentity()

newReference

public final MessageReference<X> newReference()

Specified by:

newReference in interface ServerMessage<T extends StorableMessageMetaData>

newReference

public final MessageReference<X> newReference(TransactionLogResource object)

Specified by:

newReference in interface ServerMessage<T extends StorableMessageMetaData>

isReferenced

public final boolean isReferenced(TransactionLogResource resource)

Specified by:

isReferenced in interface ServerMessage<T extends StorableMessageMetaData>

isReferenced

public final boolean isReferenced()

Specified by:

isReferenced in interface ServerMessage<T extends StorableMessageMetaData>

isPersistent

public final boolean isPersistent()

Specified by:

isPersistent in interface EnqueueableMessage

Specified by:

isPersistent in interface ServerMessage<T extends StorableMessageMetaData>

getMessageNumber

public final long getMessageNumber()

Specified by:

getMessageNumber in interface EnqueueableMessage

getContent

public final int getContent(ByteBuffer buf)

Specified by:

getContent in interface MessageContentSource

getContent

public final Collection<QpidByteBuffer> getContent()

Specified by:

getContent in interface MessageContentSource

getConnectionReference

public final Object getConnectionReference()

Specified by:

getConnectionReference in interface ServerMessage<T extends StorableMessageMetaData>

toString

public String toString()

Overrides:

toString in class Object