org.apache.qpid.server.store

Class StoredMemoryMessage<T extends StorableMessageMetaData>

java.lang.Object

org.apache.qpid.server.store.StoredMemoryMessage<T>

All Implemented Interfaces:

MessageHandle<T>, StoredMessage<T>

public class StoredMemoryMessage<T extends StorableMessageMetaData>
extends Object
implements StoredMessage<T>, MessageHandle<T>

Constructor Summary

Constructors

Constructor and Description
StoredMemoryMessage(long messageNumber, T metaData)

Method Summary

Modifier and Type	Method and Description
void	addContent(QpidByteBuffer src)
StoredMessage<T>	allContentAdded()
boolean	flowToDisk()
Collection<QpidByteBuffer>	getContent()
int	getContent(ByteBuffer dst)
long	getMessageNumber()
T	getMetaData()
boolean	isInMemory()
void	remove()

Methods inherited from class java.lang.Object

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

Constructor Detail

StoredMemoryMessage

public StoredMemoryMessage(long messageNumber,
                           T metaData)

Method Detail

getMessageNumber

public long getMessageNumber()

Specified by:

getMessageNumber in interface StoredMessage<T extends StorableMessageMetaData>

addContent

public void addContent(QpidByteBuffer src)

Specified by:

addContent in interface MessageHandle<T extends StorableMessageMetaData>

allContentAdded

public StoredMessage<T> allContentAdded()

Specified by:

allContentAdded in interface MessageHandle<T extends StorableMessageMetaData>

getContent

public int getContent(ByteBuffer dst)

Specified by:

getContent in interface StoredMessage<T extends StorableMessageMetaData>

getContent

public Collection<QpidByteBuffer> getContent()

Specified by:

getContent in interface StoredMessage<T extends StorableMessageMetaData>

getMetaData

public T getMetaData()

Specified by:

getMetaData in interface StoredMessage<T extends StorableMessageMetaData>

remove

public void remove()

Specified by:

remove in interface StoredMessage<T extends StorableMessageMetaData>

isInMemory

public boolean isInMemory()

Specified by:

isInMemory in interface StoredMessage<T extends StorableMessageMetaData>

flowToDisk

public boolean flowToDisk()

Specified by:

flowToDisk in interface StoredMessage<T extends StorableMessageMetaData>