org.apache.james.mailbox.jpa.mail.model.openjpa

Class JPAStreamingMessage

java.lang.Object

org.apache.james.mailbox.store.mail.model.AbstractMessage<Long>

org.apache.james.mailbox.jpa.mail.model.openjpa.AbstractJPAMessage

org.apache.james.mailbox.jpa.mail.model.openjpa.JPAStreamingMessage

All Implemented Interfaces:

Comparable<Message<Long>>, Message<Long>

@Entity(name="Message")
public class JPAStreamingMessage
extends AbstractJPAMessage

JPA implementation of AbstractJPAMessage which use openjpas Persistent type to be able to stream the message content without loading it into the memory at all. This is not supported for all DB's yet. See Additional JPA Mappings If your DB is not supported by this, use JPAMessage TODO: Fix me!

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.james.mailbox.jpa.mail.model.openjpa.AbstractJPAMessage

AbstractJPAMessage.MailboxIdUidKey

Constructor Summary

Constructors

Constructor and Description
JPAStreamingMessage() Deprecated.
JPAStreamingMessage(JPAMailbox mailbox, Date internalDate, int size, javax.mail.Flags flags, javax.mail.internet.SharedInputStream content, int bodyStartOctet, PropertyBuilder propertyBuilder)
JPAStreamingMessage(JPAMailbox mailbox, long uid, long modSeq, Message<?> message) Create a copy of the given message

Method Summary

Methods

Modifier and Type	Method and Description
InputStream	getBodyContent() Gets the body content of the document.
InputStream	getHeaderContent() Gets the header as InputStream.

Methods inherited from class org.apache.james.mailbox.jpa.mail.model.openjpa.AbstractJPAMessage

createUserFlags, equals, getBodyStartOctet, getFullContentOctets, getInternalDate, getMailbox, getMailboxId, getMediaType, getModSeq, getProperties, getSubType, getTextualLineCount, getUid, hashCode, isAnswered, isDeleted, isDraft, isFlagged, isRecent, isSeen, setFlags, setMailbox, setModSeq, setUid, toString

Methods inherited from class org.apache.james.mailbox.store.mail.model.AbstractMessage

compareTo, createFlags, getBodyOctets, getFullContent

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

JPAStreamingMessage

@Deprecated
public JPAStreamingMessage()

Deprecated.

JPAStreamingMessage

public JPAStreamingMessage(JPAMailbox mailbox,
                   Date internalDate,
                   int size,
                   javax.mail.Flags flags,
                   javax.mail.internet.SharedInputStream content,
                   int bodyStartOctet,
                   PropertyBuilder propertyBuilder)
                    throws MailboxException

Throws:

MailboxException

JPAStreamingMessage

public JPAStreamingMessage(JPAMailbox mailbox,
                   long uid,
                   long modSeq,
                   Message<?> message)
                    throws MailboxException

Create a copy of the given message

Parameters:

message -

Throws:

IOException

MailboxException

Method Detail

getBodyContent

public InputStream getBodyContent()
                           throws IOException

Description copied from interface: Message

Gets the body content of the document. Headers are excluded. Be aware that this method need to return a new fresh InputStream on every call, which basicly means it need to start at position 0

Returns:

body, not null

Throws:

IOException

See Also:

Message.getBodyContent()

getHeaderContent

public InputStream getHeaderContent()
                             throws IOException

Description copied from interface: Message

Gets the header as InputStream. This MUST INCLUDE the CRLF terminator Be aware that this method need to return a new fresh InputStream on every call

Returns:

header

Throws:

IOException

See Also:

Message.getHeaderContent()