Modifier and Type | Method and Description |
---|---|
static Message<UUID> |
HBaseUtils.messageMetaFromResult(org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.hbase.client.Result result)
Creates a HBaseMessage from a Result object.
|
Modifier and Type | Method and Description |
---|---|
static org.apache.hadoop.hbase.client.Delete |
HBaseUtils.flagsToDelete(Message<UUID> message,
javax.mail.Flags flags) |
static org.apache.hadoop.hbase.client.Put |
HBaseUtils.flagsToPut(Message<UUID> message,
javax.mail.Flags flags)
Utility method to transform message flags into a put opperation.
|
static byte[] |
HBaseUtils.messageRowKey(Message<UUID> message)
Create a row key for a message in a mailbox.
|
static org.apache.hadoop.hbase.client.Put |
HBaseUtils.metadataToPut(Message<UUID> message)
Transforms only the metadata into a Put object.
|
Modifier and Type | Class and Description |
---|---|
class |
HBaseMessage
Concrete HBaseMessage implementation.
|
Modifier and Type | Method and Description |
---|---|
Iterator<Message<UUID>> |
HBaseMessageMapper.findInMailbox(Mailbox<UUID> mailbox,
MessageRange set,
MessageMapper.FetchType fType,
int max) |
Modifier and Type | Method and Description |
---|---|
MessageMetaData |
HBaseMessageMapper.add(Mailbox<UUID> mailbox,
Message<UUID> message) |
MessageMetaData |
HBaseMessageMapper.copy(Mailbox<UUID> mailbox,
Message<UUID> original) |
void |
HBaseMessageMapper.delete(Mailbox<UUID> mailbox,
Message<UUID> message) |
protected MessageMetaData |
HBaseMessageMapper.save(Mailbox<UUID> mailbox,
Message<UUID> message)
|
Constructor and Description |
---|
HBaseMessage(org.apache.hadoop.conf.Configuration conf,
UUID mailboxId,
long uid,
long modSeq,
Message<?> original)
Create a copy of the given message.
|
Modifier and Type | Method and Description |
---|---|
Iterator<Message<Long>> |
InMemoryMessageMapper.findInMailbox(Mailbox<Long> mailbox,
MessageRange set,
MessageMapper.FetchType ftype,
int max) |
Modifier and Type | Method and Description |
---|---|
protected MessageMetaData |
InMemoryMessageMapper.copy(Mailbox<Long> mailbox,
long uid,
long modSeq,
Message<Long> original) |
void |
InMemoryMessageMapper.delete(Mailbox<Long> mailbox,
Message<Long> message) |
protected MessageMetaData |
InMemoryMessageMapper.save(Mailbox<Long> mailbox,
Message<Long> message) |
Modifier and Type | Method and Description |
---|---|
protected Message<String> |
JCRMessageManager.createMessage(Date internalDate,
int size,
int bodyStartOctet,
javax.mail.internet.SharedInputStream content,
javax.mail.Flags flags,
PropertyBuilder propertyBuilder) |
Modifier and Type | Method and Description |
---|---|
Iterator<Message<String>> |
JCRMessageMapper.findInMailbox(Mailbox<String> mailbox,
MessageRange set,
MessageMapper.FetchType fType,
int max) |
Modifier and Type | Method and Description |
---|---|
protected MessageMetaData |
JCRMessageMapper.copy(Mailbox<String> mailbox,
long uid,
long modSeq,
Message<String> original) |
void |
JCRMessageMapper.delete(Mailbox<String> mailbox,
Message<String> message) |
protected MessageMetaData |
JCRMessageMapper.save(Mailbox<String> mailbox,
Message<String> message) |
Modifier and Type | Class and Description |
---|---|
class |
JCRMessage
JCR implementation of
Message |
Modifier and Type | Method and Description |
---|---|
protected Message<Long> |
JPAMessageManager.createMessage(Date internalDate,
int size,
int bodyStartOctet,
javax.mail.internet.SharedInputStream content,
javax.mail.Flags flags,
PropertyBuilder propertyBuilder) |
Modifier and Type | Method and Description |
---|---|
Iterator<Message<Long>> |
JPAMessageMapper.findInMailbox(Mailbox<Long> mailbox,
MessageRange set,
MessageMapper.FetchType fType,
int max) |
Modifier and Type | Method and Description |
---|---|
protected MessageMetaData |
JPAMessageMapper.copy(Mailbox<Long> mailbox,
long uid,
long modSeq,
Message<Long> original) |
void |
JPAMessageMapper.delete(Mailbox<Long> mailbox,
Message<Long> message) |
protected MessageMetaData |
JPAMessageMapper.save(Mailbox<Long> mailbox,
Message<Long> message) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractJPAMessage
Abstract base class for JPA based implementations of
AbstractMessage |
class |
JPAEncryptedMessage |
class |
JPAMessage |
class |
JPAStreamingMessage
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. |
Constructor and Description |
---|
AbstractJPAMessage(JPAMailbox mailbox,
long uid,
long modSeq,
Message<?> original)
Constructs a copy of the given message.
|
JPAEncryptedMessage(JPAMailbox mailbox,
long uid,
long modSeq,
Message<?> message)
Create a copy of the given message
|
JPAMessage(JPAMailbox mailbox,
long uid,
long modSeq,
Message<?> message)
Create a copy of the given message
|
JPAStreamingMessage(JPAMailbox mailbox,
long uid,
long modSeq,
Message<?> message)
Create a copy of the given message
|
Modifier and Type | Method and Description |
---|---|
protected Message<Long> |
OpenJPAMessageManager.createMessage(Date internalDate,
int size,
int bodyStartOctet,
javax.mail.internet.SharedInputStream content,
javax.mail.Flags flags,
PropertyBuilder propertyBuilder) |
Modifier and Type | Method and Description |
---|---|
void |
LuceneMessageSearchIndex.add(MailboxSession session,
Mailbox<Id> mailbox,
Message<Id> membership) |
Modifier and Type | Method and Description |
---|---|
Iterator<Message<Integer>> |
MaildirMessageMapper.findInMailbox(Mailbox<Integer> mailbox,
MessageRange set,
MessageMapper.FetchType fType,
int max) |
Modifier and Type | Method and Description |
---|---|
protected MessageMetaData |
MaildirMessageMapper.copy(Mailbox<Integer> mailbox,
long uid,
long modSeq,
Message<Integer> original) |
void |
MaildirMessageMapper.delete(Mailbox<Integer> mailbox,
Message<Integer> message) |
protected MessageMetaData |
MaildirMessageMapper.save(Mailbox<Integer> mailbox,
Message<Integer> message) |
Modifier and Type | Class and Description |
---|---|
class |
MaildirMessage |
Modifier and Type | Method and Description |
---|---|
protected Message<Id> |
StoreMessageManager.createMessage(Date internalDate,
int size,
int bodyStartOctet,
javax.mail.internet.SharedInputStream content,
javax.mail.Flags flags,
PropertyBuilder propertyBuilder)
Create a new
Message for the given data |
Modifier and Type | Method and Description |
---|---|
protected MessageMetaData |
StoreMessageManager.appendMessageToStore(Message<Id> message,
MailboxSession session) |
static List<MessageResult.Header> |
ResultUtils.createHeaders(Message<?> document) |
static MessageResult |
ResultUtils.loadMessageResult(Message<?> message,
MessageResult.FetchGroup fetchGroup)
|
Constructor and Description |
---|
LazyMimeDescriptor(MessageResult result,
Message<?> message) |
MessageResultImpl(Message<?> message) |
SimpleMessageMetaData(Message<?> message) |
Modifier and Type | Method and Description |
---|---|
Iterator<Message<Id>> |
MessageMapper.findInMailbox(Mailbox<Id> mailbox,
MessageRange set,
MessageMapper.FetchType type,
int limit)
|
Modifier and Type | Method and Description |
---|---|
MessageMetaData |
AbstractMessageMapper.add(Mailbox<Id> mailbox,
Message<Id> message) |
MessageMetaData |
MessageMapper.add(Mailbox<Id> mailbox,
Message<Id> message)
Add the given
Message to the underlying storage. |
protected abstract MessageMetaData |
AbstractMessageMapper.copy(Mailbox<Id> mailbox,
long uid,
long modSeq,
Message<Id> original)
Copy the Message to the Mailbox, using the given uid and modSeq for the new Message
|
MessageMetaData |
AbstractMessageMapper.copy(Mailbox<Id> mailbox,
Message<Id> original) |
MessageMetaData |
MessageMapper.copy(Mailbox<Id> mailbox,
Message<Id> original)
Copy the given
Message to a new mailbox and return the uid of the copy. |
void |
MessageMapper.delete(Mailbox<Id> mailbox,
Message<Id> message)
Delete the given
Message |
protected abstract MessageMetaData |
AbstractMessageMapper.save(Mailbox<Id> mailbox,
Message<Id> message)
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractMessage<Id>
Abstract base class for
Message |
Modifier and Type | Method and Description |
---|---|
int |
AbstractMessage.compareTo(Message<Id> other) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleMessage<Id> |
Constructor and Description |
---|
SimpleMessage(Mailbox<Id> mailbox,
Message<Id> original) |
Modifier and Type | Method and Description |
---|---|
abstract void |
ListeningMessageSearchIndex.add(MailboxSession session,
Mailbox<Id> mailbox,
Message<Id> message)
|
void |
LazyMessageSearchIndex.add(MailboxSession session,
Mailbox<Id> mailbox,
Message<Id> message) |
static boolean |
MessageSearches.isMatch(SearchQuery.Criterion criterion,
Message<?> message,
Collection<Long> recentMessageUids,
org.slf4j.Logger log)
Does the row match the given criterion?
|
static boolean |
MessageSearches.isMatch(SearchQuery query,
Message<?> message,
org.slf4j.Logger log)
Does the row match the given criteria?
|
Constructor and Description |
---|
MessageSearches(Iterator<Message<?>> messages,
SearchQuery query) |
MessageSearches(Iterator<Message<?>> messages,
SearchQuery query,
org.slf4j.Logger log) |
Modifier and Type | Method and Description |
---|---|
static Comparator<Message<?>> |
BaseSubjectComparator.baseSubject(boolean reverse) |
static Comparator<Message<?>> |
HeaderMailboxComparator.cc(boolean reverse) |
static Comparator<Message<?>> |
CombinedComparator.create(List<SearchQuery.Sort> sorts) |
static Comparator<Message<?>> |
HeaderMailboxComparator.from(boolean reverse) |
static Comparator<Message<?>> |
HeaderDisplayComparator.from(boolean reverse) |
static Comparator<Message<?>> |
InternalDateComparator.internalDate(boolean reverse) |
static Comparator<Message<?>> |
SentDateComparator.sentDate(boolean reverse) |
static Comparator<Message<?>> |
SizeComparator.size(boolean reverse) |
static Comparator<Message<?>> |
HeaderMailboxComparator.to(boolean reverse) |
static Comparator<Message<?>> |
HeaderDisplayComparator.to(boolean reverse) |
static Comparator<Message<?>> |
UidComparator.uid(boolean reverse) |
Modifier and Type | Method and Description |
---|---|
int |
ReverseComparator.compare(Message<?> o1,
Message<?> o2) |
int |
ReverseComparator.compare(Message<?> o1,
Message<?> o2) |
int |
HeaderMailboxComparator.compare(Message<?> o1,
Message<?> o2) |
int |
HeaderMailboxComparator.compare(Message<?> o1,
Message<?> o2) |
int |
SizeComparator.compare(Message<?> o1,
Message<?> o2) |
int |
SizeComparator.compare(Message<?> o1,
Message<?> o2) |
int |
BaseSubjectComparator.compare(Message<?> o1,
Message<?> o2) |
int |
BaseSubjectComparator.compare(Message<?> o1,
Message<?> o2) |
int |
UidComparator.compare(Message<?> o1,
Message<?> o2) |
int |
UidComparator.compare(Message<?> o1,
Message<?> o2) |
int |
SentDateComparator.compare(Message<?> o1,
Message<?> o2) |
int |
SentDateComparator.compare(Message<?> o1,
Message<?> o2) |
int |
HeaderDisplayComparator.compare(Message<?> o1,
Message<?> o2) |
int |
HeaderDisplayComparator.compare(Message<?> o1,
Message<?> o2) |
int |
InternalDateComparator.compare(Message<?> o1,
Message<?> o2) |
int |
InternalDateComparator.compare(Message<?> o1,
Message<?> o2) |
int |
CombinedComparator.compare(Message<?> o1,
Message<?> o2) |
int |
CombinedComparator.compare(Message<?> o1,
Message<?> o2) |
protected String |
AbstractHeaderComparator.getHeaderValue(String headerName,
Message<?> message) |
Constructor and Description |
---|
ReverseComparator(Comparator<Message<?>> comparator) |
Constructor and Description |
---|
InputStreamContent(Message<?> m,
InputStreamContent.Type type) |
Copyright © 2010-2012 The Apache Software Foundation. All Rights Reserved.