Author: norman
Date: Fri Jun 17 11:26:06 2011
New Revision: 1136845
URL: http://svn.apache.org/viewvc?rev=1136845&view=rev
Log:
Move MessageMembershipCallback to MessageMapper and rename it to MessageCallback
Modified:
james/mailbox/trunk/jcr/src/main/java/org/apache/james/mailbox/jcr/mail/JCRMessageMapper.java
james/mailbox/trunk/jpa/src/main/java/org/apache/james/mailbox/jpa/mail/JPAMessageMapper.java
james/mailbox/trunk/maildir/src/main/java/org/apache/james/mailbox/maildir/mail/MaildirMessageMapper.java
james/mailbox/trunk/memory/src/main/java/org/apache/james/mailbox/inmemory/mail/InMemoryMessageMapper.java
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/StoreMessageManager.java
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/mail/AbstractMessageMapper.java
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/mail/MessageMapper.java
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/quota/ListeningQuotaManager.java
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/LazyMessageSearchIndex.java
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/ListeningMessageSearchIndex.java
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/SimpleMessageSearchIndex.java
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/transaction/Mapper.java
Modified:
james/mailbox/trunk/jcr/src/main/java/org/apache/james/mailbox/jcr/mail/JCRMessageMapper.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/jcr/src/main/java/org/apache/james/mailbox/jcr/mail/JCRMessageMapper.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/jcr/src/main/java/org/apache/james/mailbox/jcr/mail/JCRMessageMapper.java
(original)
+++
james/mailbox/trunk/jcr/src/main/java/org/apache/james/mailbox/jcr/mail/JCRMessageMapper.java
Fri Jun 17 11:26:06 2011
@@ -260,7 +260,7 @@ public class JCRMessageMapper extends Ab
* .james.imap.mailbox.MessageRange)
*/
public void findInMailbox(Mailbox<String> mailbox, MessageRange set,
- MailboxMembershipCallback<String> callback) throws
MailboxException {
+ MessageCallback<String> callback) throws MailboxException {
try {
List<Message<String>> results;
long from = set.getUidFrom();
@@ -286,7 +286,7 @@ public class JCRMessageMapper extends Ab
}
if(results.size() > 0) {
- callback.onMailboxMembers(results);
+ callback.onMessages(results);
// move the start UID behind the last
fetched message UID
from =
results.get(results.size()-1).getUid()+1;
Modified:
james/mailbox/trunk/jpa/src/main/java/org/apache/james/mailbox/jpa/mail/JPAMessageMapper.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/jpa/src/main/java/org/apache/james/mailbox/jpa/mail/JPAMessageMapper.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/jpa/src/main/java/org/apache/james/mailbox/jpa/mail/JPAMessageMapper.java
(original)
+++
james/mailbox/trunk/jpa/src/main/java/org/apache/james/mailbox/jpa/mail/JPAMessageMapper.java
Fri Jun 17 11:26:06 2011
@@ -118,7 +118,7 @@ public class JPAMessageMapper extends Ab
/**
* @see
org.apache.james.mailbox.store.mail.MessageMapper#findInMailbox(org.apache.james.mailbox.MessageRange)
*/
- public void findInMailbox(Mailbox<Long> mailbox, MessageRange set,
MailboxMembershipCallback<Long> callback) throws MailboxException {
+ public void findInMailbox(Mailbox<Long> mailbox, MessageRange set,
MessageCallback<Long> callback) throws MailboxException {
try {
List<Message<Long>> results;
long from = set.getUidFrom();
@@ -146,7 +146,7 @@ public class JPAMessageMapper extends Ab
}
if (results.size() > 0) {
- callback.onMailboxMembers(results);
+ callback.onMessages(results);
// move the start UID behind the last fetched message UID
from = results.get(results.size() - 1).getUid() + 1;
Modified:
james/mailbox/trunk/maildir/src/main/java/org/apache/james/mailbox/maildir/mail/MaildirMessageMapper.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/maildir/src/main/java/org/apache/james/mailbox/maildir/mail/MaildirMessageMapper.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/maildir/src/main/java/org/apache/james/mailbox/maildir/mail/MaildirMessageMapper.java
(original)
+++
james/mailbox/trunk/maildir/src/main/java/org/apache/james/mailbox/maildir/mail/MaildirMessageMapper.java
Fri Jun 17 11:26:06 2011
@@ -115,7 +115,7 @@ public class MaildirMessageMapper extend
* (non-Javadoc)
* @see
org.apache.james.mailbox.store.mail.MessageMapper#findInMailbox(org.apache.james.mailbox.store.mail.model.Mailbox,
org.apache.james.mailbox.MessageRange)
*/
- public void findInMailbox(Mailbox<Integer> mailbox, MessageRange set,
MailboxMembershipCallback<Integer> callback)
+ public void findInMailbox(Mailbox<Integer> mailbox, MessageRange set,
MessageCallback<Integer> callback)
throws MailboxException {
final List<Message<Integer>> results;
final long from = set.getUidFrom();
@@ -141,11 +141,11 @@ public class MaildirMessageMapper extend
if (batchSize > 0) {
int i = 0;
while (i * batchSize < results.size()) {
- callback.onMailboxMembers(results.subList(i * batchSize, (i +
1) * batchSize < results.size() ? (i + 1) * batchSize : results.size()));
+ callback.onMessages(results.subList(i * batchSize, (i + 1) *
batchSize < results.size() ? (i + 1) * batchSize : results.size()));
i++;
}
} else {
- callback.onMailboxMembers(results);
+ callback.onMessages(results);
}
}
@@ -474,9 +474,9 @@ public class MaildirMessageMapper extend
final List<UpdatedFlags> updatedFlags = new ArrayList<UpdatedFlags>();
final MaildirFolder folder = maildirStore.createMaildirFolder(mailbox);
- findInMailbox(mailbox, set, new MailboxMembershipCallback<Integer>() {
+ findInMailbox(mailbox, set, new MessageCallback<Integer>() {
- public void onMailboxMembers(List<Message<Integer>> members)
throws MailboxException {
+ public void onMessages(List<Message<Integer>> members) throws
MailboxException {
for (final Message<Integer> member : members) {
Flags originalFlags = member.createFlags();
if (replace) {
Modified:
james/mailbox/trunk/memory/src/main/java/org/apache/james/mailbox/inmemory/mail/InMemoryMessageMapper.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/memory/src/main/java/org/apache/james/mailbox/inmemory/mail/InMemoryMessageMapper.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/memory/src/main/java/org/apache/james/mailbox/inmemory/mail/InMemoryMessageMapper.java
(original)
+++
james/mailbox/trunk/memory/src/main/java/org/apache/james/mailbox/inmemory/mail/InMemoryMessageMapper.java
Fri Jun 17 11:26:06 2011
@@ -90,7 +90,7 @@ public class InMemoryMessageMapper exten
* (non-Javadoc)
* @see
org.apache.james.mailbox.store.mail.MessageMapper#findInMailbox(java.lang.Object,
org.apache.james.mailbox.MessageRange)
*/
- public void findInMailbox(Mailbox<Long> mailbox, MessageRange set,
MailboxMembershipCallback<Long> callback) throws MailboxException {
+ public void findInMailbox(Mailbox<Long> mailbox, MessageRange set,
MessageCallback<Long> callback) throws MailboxException {
final List<Message<Long>> results;
final int batchSize = set.getBatchSize();
final MessageRange.Type type = set.getType();
@@ -131,11 +131,11 @@ public class InMemoryMessageMapper exten
if(batchSize > 0) {
int i = 0;
while(i*batchSize < results.size()) {
- callback.onMailboxMembers(results.subList(i*batchSize,
(i+1)*batchSize < results.size() ? (i+1)*batchSize : results.size()));
+ callback.onMessages(results.subList(i*batchSize,
(i+1)*batchSize < results.size() ? (i+1)*batchSize : results.size()));
i++;
}
} else {
- callback.onMailboxMembers(results);
+ callback.onMessages(results);
}
}
@@ -147,9 +147,9 @@ public class InMemoryMessageMapper exten
public Map<Long, MessageMetaData> expungeMarkedForDeletion(final
Mailbox<Long> mailbox, MessageRange set) throws MailboxException {
final Map<Long, MessageMetaData> filteredResult = new HashMap<Long,
MessageMetaData>();
- findInMailbox(mailbox, set, new MailboxMembershipCallback<Long>() {
+ findInMailbox(mailbox, set, new MessageCallback<Long>() {
- public void onMailboxMembers(List<Message<Long>> results) throws
MailboxException {
+ public void onMessages(List<Message<Long>> results) throws
MailboxException {
for (final Iterator<Message<Long>> it = results.iterator();
it.hasNext();) {
Message<Long> member = it.next();
if (member.isDeleted()) {
Modified:
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/StoreMessageManager.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/StoreMessageManager.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/StoreMessageManager.java
(original)
+++
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/StoreMessageManager.java
Fri Jun 17 11:26:06 2011
@@ -58,7 +58,6 @@ import org.apache.james.mailbox.store.st
import org.apache.james.mailbox.store.streaming.ConfigurableMimeTokenStream;
import org.apache.james.mailbox.store.streaming.CountingInputStream;
import org.apache.james.mailbox.store.transaction.Mapper;
-import
org.apache.james.mailbox.store.transaction.Mapper.MailboxMembershipCallback;
import org.apache.james.mime4j.MimeException;
import org.apache.james.mime4j.descriptor.MaximalBodyDescriptor;
import org.apache.james.mime4j.message.Header;
@@ -535,8 +534,8 @@ public abstract class StoreMessageManage
*/
public void getMessages(MessageRange set, final FetchGroup fetchGroup,
MailboxSession mailboxSession, final MessageCallback messageCallback) throws
MailboxException {
-
mapperFactory.getMessageMapper(mailboxSession).findInMailbox(getMailboxEntity(),
set, new MailboxMembershipCallback<Id>() {
- public void onMailboxMembers(List<Message<Id>> rows) throws
MailboxException {
+
mapperFactory.getMessageMapper(mailboxSession).findInMailbox(getMailboxEntity(),
set, new
org.apache.james.mailbox.store.mail.MessageMapper.MessageCallback<Id>() {
+ public void onMessages(List<Message<Id>> rows) throws
MailboxException {
messageCallback.onMessages(new
ResultIterator<Id>(rows.iterator(), fetchGroup));
}
});
@@ -630,9 +629,9 @@ public abstract class StoreMessageManage
MessageMapper<Id> messageMapper =
mapperFactory.getMessageMapper(session);
final Map<Long, MessageMetaData> copiedMessages = new
HashMap<Long, MessageMetaData>();
- messageMapper.findInMailbox(getMailboxEntity(), set, new
MailboxMembershipCallback<Id>() {
+ messageMapper.findInMailbox(getMailboxEntity(), set, new
org.apache.james.mailbox.store.mail.MessageMapper.MessageCallback<Id>() {
- public void onMailboxMembers(List<Message<Id>> originalRows)
throws MailboxException {
+ public void onMessages(List<Message<Id>> originalRows) throws
MailboxException {
Iterator<MessageMetaData> ids = to.copy(originalRows,
session);
while (ids.hasNext()) {
MessageMetaData data = ids.next();
Modified:
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/mail/AbstractMessageMapper.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/mail/AbstractMessageMapper.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/mail/AbstractMessageMapper.java
(original)
+++
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/mail/AbstractMessageMapper.java
Fri Jun 17 11:26:06 2011
@@ -170,9 +170,9 @@ public abstract class AbstractMessageMap
*/
public Iterator<UpdatedFlags> updateFlags(final Mailbox<Id> mailbox, final
Flags flags, final boolean value, final boolean replace, final MessageRange
set) throws MailboxException {
final List<UpdatedFlags> updatedFlags = new ArrayList<UpdatedFlags>();
- findInMailbox(mailbox, set, new MailboxMembershipCallback<Id>() {
+ findInMailbox(mailbox, set, new MessageCallback<Id>() {
- public void onMailboxMembers(List<Message<Id>> members) throws
MailboxException {
+ public void onMessages(List<Message<Id>> members) throws
MailboxException {
long modSeq = -1;
if (members.isEmpty() == false) {
Modified:
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/mail/MessageMapper.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/mail/MessageMapper.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/mail/MessageMapper.java
(original)
+++
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/mail/MessageMapper.java
Fri Jun 17 11:26:06 2011
@@ -47,9 +47,9 @@ public interface MessageMapper<Id> exten
* @param callback callback object
* @throws MailboxException
*/
- public abstract void findInMailbox(Mailbox<Id> mailbox, MessageRange set,
MailboxMembershipCallback<Id> callback)
+ public abstract void findInMailbox(Mailbox<Id> mailbox, MessageRange set,
MessageCallback<Id> callback)
throws MailboxException;
-
+
/**
* Return a {@link Iterator} which holds the uids for all deleted Messages
for the given {@link MessageRange} which are marked for deletion
* The list must be ordered
@@ -170,5 +170,17 @@ public interface MessageMapper<Id> exten
* @throws MailboxException
*/
public abstract long getHighestModSeq(Mailbox<Id> mailbox) throws
MailboxException;
+
+
+ public interface MessageCallback<Id> {
+
+ /**
+ * Callback which get executed for a {@link List} of {@link Message}'s
+ *
+ * @param list
+ * @throws MailboxException
+ */
+ void onMessages(List<Message<Id>> list) throws MailboxException;
+ }
}
\ No newline at end of file
Modified:
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/quota/ListeningQuotaManager.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/quota/ListeningQuotaManager.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/quota/ListeningQuotaManager.java
(original)
+++
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/quota/ListeningQuotaManager.java
Fri Jun 17 11:26:06 2011
@@ -34,7 +34,7 @@ import org.apache.james.mailbox.store.Ma
import org.apache.james.mailbox.store.StoreMailboxManager;
import org.apache.james.mailbox.store.mail.model.Mailbox;
import org.apache.james.mailbox.store.mail.model.Message;
-import
org.apache.james.mailbox.store.transaction.Mapper.MailboxMembershipCallback;
+import org.apache.james.mailbox.store.mail.MessageMapper.MessageCallback;
/**
* {@link QuotaManager} which will keep track of quota by listing for {@link
Event}'s.
@@ -98,11 +98,11 @@ public abstract class ListeningQuotaMana
final AtomicLong mSizes = new AtomicLong(0);
List<Mailbox> mailboxes =
factory.getMailboxMapper(session).findMailboxWithPathLike(new
MailboxPath(session.getPersonalSpace(), id, "%"));
for (int i = 0; i < mailboxes.size(); i++) {
-
factory.getMessageMapper(session).findInMailbox(mailboxes.get(i),
MessageRange.all(), new MailboxMembershipCallback<Object>() {
+
factory.getMessageMapper(session).findInMailbox(mailboxes.get(i),
MessageRange.all(), new MessageCallback<Object>() {
long messageSizes = 0;
@Override
- public void onMailboxMembers(List<Message<Object>>
list) throws MailboxException {
+ public void onMessages(List<Message<Object>> list)
throws MailboxException {
for (int i = 0; i < list.size(); i++) {
messageSizes +=
list.get(i).getFullContentOctets();
}
Modified:
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/LazyMessageSearchIndex.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/LazyMessageSearchIndex.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/LazyMessageSearchIndex.java
(original)
+++
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/LazyMessageSearchIndex.java
Fri Jun 17 11:26:06 2011
@@ -28,9 +28,9 @@ import org.apache.james.mailbox.MailboxE
import org.apache.james.mailbox.MailboxSession;
import org.apache.james.mailbox.MessageRange;
import org.apache.james.mailbox.SearchQuery;
+import org.apache.james.mailbox.store.mail.MessageMapper.MessageCallback;
import org.apache.james.mailbox.store.mail.model.Mailbox;
import org.apache.james.mailbox.store.mail.model.Message;
-import
org.apache.james.mailbox.store.transaction.Mapper.MailboxMembershipCallback;
/**
* {@link ListeningMessageSearchIndex} implementation which wraps another
{@link ListeningMessageSearchIndex} and will forward all calls to it.
@@ -83,10 +83,10 @@ public class LazyMessageSearchIndex<Id>
done = oldDone;
}
synchronized (done) {
- getFactory().getMessageMapper(session).findInMailbox(mailbox,
MessageRange.all(), new MailboxMembershipCallback<Id>() {
+ getFactory().getMessageMapper(session).findInMailbox(mailbox,
MessageRange.all(), new MessageCallback<Id>() {
@Override
- public void onMailboxMembers(List<Message<Id>> list)
throws MailboxException {
+ public void onMessages(List<Message<Id>> list) throws
MailboxException {
for (int i = 0; i < list.size(); i++) {
final Message<Id> message = list.get(i);
Modified:
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/ListeningMessageSearchIndex.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/ListeningMessageSearchIndex.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/ListeningMessageSearchIndex.java
(original)
+++
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/ListeningMessageSearchIndex.java
Fri Jun 17 11:26:06 2011
@@ -32,10 +32,10 @@ import org.apache.james.mailbox.store.Ma
import org.apache.james.mailbox.store.MailboxEventDispatcher.ExpungedImpl;
import org.apache.james.mailbox.store.MailboxEventDispatcher.FlagsUpdatedImpl;
import
org.apache.james.mailbox.store.MailboxEventDispatcher.MailboxDeletionImpl;
+import org.apache.james.mailbox.store.mail.MessageMapper.MessageCallback;
import org.apache.james.mailbox.store.mail.MessageMapperFactory;
import org.apache.james.mailbox.store.mail.model.Mailbox;
import org.apache.james.mailbox.store.mail.model.Message;
-import
org.apache.james.mailbox.store.transaction.Mapper.MailboxMembershipCallback;
/**
* {@link MessageSearchIndex} which needs to get registered as global {@link
MailboxListener} and so get
@@ -80,10 +80,10 @@ public abstract class ListeningMessageSe
while (uids.hasNext()) {
long next = uids.next();
-
factory.getMessageMapper(session).findInMailbox(mailbox,
MessageRange.one(next), new MailboxMembershipCallback<Id>() {
+
factory.getMessageMapper(session).findInMailbox(mailbox,
MessageRange.one(next), new MessageCallback<Id>() {
@Override
- public void onMailboxMembers(List<Message<Id>>
list) throws MailboxException {
+ public void onMessages(List<Message<Id>> list)
throws MailboxException {
for (int i = 0; i < list.size(); i++) {
Message<Id> message = list.get(i);
try {
Modified:
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/SimpleMessageSearchIndex.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/SimpleMessageSearchIndex.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/SimpleMessageSearchIndex.java
(original)
+++
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/search/SimpleMessageSearchIndex.java
Fri Jun 17 11:26:06 2011
@@ -31,10 +31,10 @@ import org.apache.james.mailbox.SearchQu
import org.apache.james.mailbox.SearchQuery.NumericRange;
import org.apache.james.mailbox.SearchQuery.UidCriterion;
import org.apache.james.mailbox.store.mail.MessageMapper;
+import org.apache.james.mailbox.store.mail.MessageMapper.MessageCallback;
import org.apache.james.mailbox.store.mail.MessageMapperFactory;
import org.apache.james.mailbox.store.mail.model.Mailbox;
import org.apache.james.mailbox.store.mail.model.Message;
-import
org.apache.james.mailbox.store.transaction.Mapper.MailboxMembershipCallback;
/**
* {@link MessageSearchIndex} which just fetch {@link Message}'s from the
{@link MessageMapper} and use {@link MessageSearcher}
@@ -64,9 +64,9 @@ public class SimpleMessageSearchIndex<Id
NumericRange[] ranges = uidCrit.getOperator().getRange();
for (int i = 0; i < ranges.length; i++) {
NumericRange r = ranges[i];
- mapper.findInMailbox(mailbox,
MessageRange.range(r.getLowValue(), r.getHighValue()), new
MailboxMembershipCallback<Id>() {
+ mapper.findInMailbox(mailbox,
MessageRange.range(r.getLowValue(), r.getHighValue()), new
MessageCallback<Id>() {
- public void onMailboxMembers(List<Message<Id>> list)
throws MailboxException {
+ public void onMessages(List<Message<Id>> list) throws
MailboxException {
for (int i = 0; i < list.size(); i++) {
long uid = list.get(i).getUid();
if (uids.contains(uid) == false) {
@@ -84,9 +84,9 @@ public class SimpleMessageSearchIndex<Id
final List<Message<Id>> hits = new ArrayList<Message<Id>>();
- mapper.findInMailbox(mailbox, MessageRange.all(), new
MailboxMembershipCallback<Id>() {
+ mapper.findInMailbox(mailbox, MessageRange.all(), new
MessageCallback<Id>() {
- public void onMailboxMembers(List<Message<Id>> list) throws
MailboxException {
+ public void onMessages(List<Message<Id>> list) throws
MailboxException {
for (int i = 0; i < list.size(); i++) {
Message<Id> m = list.get(i);
if (hits.contains(m) == false) {
Modified:
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/transaction/Mapper.java
URL:
http://svn.apache.org/viewvc/james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/transaction/Mapper.java?rev=1136845&r1=1136844&r2=1136845&view=diff
==============================================================================
---
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/transaction/Mapper.java
(original)
+++
james/mailbox/trunk/store/src/main/java/org/apache/james/mailbox/store/transaction/Mapper.java
Fri Jun 17 11:26:06 2011
@@ -19,10 +19,7 @@
package org.apache.james.mailbox.store.transaction;
-import java.util.List;
-
import org.apache.james.mailbox.MailboxException;
-import org.apache.james.mailbox.store.mail.model.Message;
/**
* Mapper which execute units of work in a {@link Transaction}
@@ -57,9 +54,6 @@ public interface Mapper {
public T run() throws MailboxException;
}
- public interface MailboxMembershipCallback<Id> {
- void onMailboxMembers(List<Message<Id>> list) throws MailboxException;
- }
public abstract class VoidTransaction implements Transaction<Void> {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
