You are viewing a plain text version of this content. The canonical link for it is here.
Posted to server-dev@james.apache.org by ma...@apache.org on 2016/01/12 14:13:19 UTC
svn commit: r1724224 -
/james/project/trunk/mailbox/caching/src/main/java/org/apache/james/mailbox/caching/CachingMessageMapper.java
Author: matthieu
Date: Tue Jan 12 13:13:19 2016
New Revision: 1724224
URL: http://svn.apache.org/viewvc?rev=1724224&view=rev
Log:
MAILBOX-262 convert tabs to spaces in CachingMessageMapper
Modified:
james/project/trunk/mailbox/caching/src/main/java/org/apache/james/mailbox/caching/CachingMessageMapper.java
Modified: james/project/trunk/mailbox/caching/src/main/java/org/apache/james/mailbox/caching/CachingMessageMapper.java
URL: http://svn.apache.org/viewvc/james/project/trunk/mailbox/caching/src/main/java/org/apache/james/mailbox/caching/CachingMessageMapper.java?rev=1724224&r1=1724223&r2=1724224&view=diff
==============================================================================
--- james/project/trunk/mailbox/caching/src/main/java/org/apache/james/mailbox/caching/CachingMessageMapper.java (original)
+++ james/project/trunk/mailbox/caching/src/main/java/org/apache/james/mailbox/caching/CachingMessageMapper.java Tue Jan 12 13:13:19 2016
@@ -21,111 +21,111 @@ import org.apache.james.mailbox.store.ma
*/
public class CachingMessageMapper<Id extends MailboxId> implements MessageMapper<Id> {
-
- private MessageMapper<Id> underlying;
- private MailboxMetadataCache<Id> cache;
-
- public CachingMessageMapper(MessageMapper<Id> underlying, MailboxMetadataCache<Id> cache) {
- this.underlying = underlying;
- this.cache = cache;
- }
-
- @Override
- public void endRequest() {
- underlying.endRequest();
- }
-
- @Override
- public <T> T execute(Transaction<T> transaction) throws MailboxException {
- return underlying.execute(transaction);
- }
-
- @Override
- public Iterator<Message<Id>> findInMailbox(Mailbox<Id> mailbox,
- MessageRange set,
- org.apache.james.mailbox.store.mail.MessageMapper.FetchType type,
- int limit) throws MailboxException {
- return underlying.findInMailbox(mailbox, set, type, limit);
- }
-
- @Override
- public Map<Long, MessageMetaData> expungeMarkedForDeletionInMailbox(
- Mailbox<Id> mailbox, MessageRange set) throws MailboxException {
- invalidateMetadata(mailbox);
- return underlying.expungeMarkedForDeletionInMailbox(mailbox, set);
- }
-
- @Override
- public long countMessagesInMailbox(Mailbox<Id> mailbox)
- throws MailboxException {
- return cache.countMessagesInMailbox(mailbox, underlying);
- }
-
- @Override
- public long countUnseenMessagesInMailbox(Mailbox<Id> mailbox)
- throws MailboxException {
- return cache.countUnseenMessagesInMailbox(mailbox, underlying);
- }
-
- @Override
- public void delete(Mailbox<Id> mailbox, Message<Id> message)
- throws MailboxException {
- invalidateMetadata(mailbox);
- underlying.delete(mailbox, message);
-
- }
-
- @Override
- public Long findFirstUnseenMessageUid(Mailbox<Id> mailbox)
- throws MailboxException {
- return cache.findFirstUnseenMessageUid(mailbox, underlying);
- }
-
- @Override
- public List<Long> findRecentMessageUidsInMailbox(Mailbox<Id> mailbox)
- throws MailboxException {
- // TODO can be meaningfully cached?
- return underlying.findRecentMessageUidsInMailbox(mailbox);
- }
-
- @Override
- public MessageMetaData add(Mailbox<Id> mailbox, Message<Id> message)
- throws MailboxException {
- invalidateMetadata(mailbox);
- return underlying.add(mailbox, message);
- }
-
- @Override
- public Iterator<UpdatedFlags> updateFlags(Mailbox<Id> mailbox, FlagsUpdateCalculator calculator, MessageRange set)
- throws MailboxException {
- //check if there are in fact any updates
- if (set.iterator().hasNext())
- invalidateMetadata(mailbox);
- return underlying.updateFlags(mailbox, calculator, set);
- }
-
-
- @Override
- public MessageMetaData copy(Mailbox<Id> mailbox, Message<Id> original)
- throws MailboxException {
- invalidateMetadata(mailbox);
- return underlying.copy(mailbox, original);
- }
-
- @Override
- public long getLastUid(Mailbox<Id> mailbox) throws MailboxException {
- return cache.getLastUid(mailbox, underlying);
- }
-
- @Override
- public long getHighestModSeq(Mailbox<Id> mailbox) throws MailboxException {
- return cache.getHighestModSeq(mailbox, underlying);
- }
-
- private void invalidateMetadata(Mailbox<Id> mailbox) {
- cache.invalidate(mailbox);
-
- }
+
+ private MessageMapper<Id> underlying;
+ private MailboxMetadataCache<Id> cache;
+
+ public CachingMessageMapper(MessageMapper<Id> underlying, MailboxMetadataCache<Id> cache) {
+ this.underlying = underlying;
+ this.cache = cache;
+ }
+
+ @Override
+ public void endRequest() {
+ underlying.endRequest();
+ }
+
+ @Override
+ public <T> T execute(Transaction<T> transaction) throws MailboxException {
+ return underlying.execute(transaction);
+ }
+
+ @Override
+ public Iterator<Message<Id>> findInMailbox(Mailbox<Id> mailbox,
+ MessageRange set,
+ org.apache.james.mailbox.store.mail.MessageMapper.FetchType type,
+ int limit) throws MailboxException {
+ return underlying.findInMailbox(mailbox, set, type, limit);
+ }
+
+ @Override
+ public Map<Long, MessageMetaData> expungeMarkedForDeletionInMailbox(
+ Mailbox<Id> mailbox, MessageRange set) throws MailboxException {
+ invalidateMetadata(mailbox);
+ return underlying.expungeMarkedForDeletionInMailbox(mailbox, set);
+ }
+
+ @Override
+ public long countMessagesInMailbox(Mailbox<Id> mailbox)
+ throws MailboxException {
+ return cache.countMessagesInMailbox(mailbox, underlying);
+ }
+
+ @Override
+ public long countUnseenMessagesInMailbox(Mailbox<Id> mailbox)
+ throws MailboxException {
+ return cache.countUnseenMessagesInMailbox(mailbox, underlying);
+ }
+
+ @Override
+ public void delete(Mailbox<Id> mailbox, Message<Id> message)
+ throws MailboxException {
+ invalidateMetadata(mailbox);
+ underlying.delete(mailbox, message);
+
+ }
+
+ @Override
+ public Long findFirstUnseenMessageUid(Mailbox<Id> mailbox)
+ throws MailboxException {
+ return cache.findFirstUnseenMessageUid(mailbox, underlying);
+ }
+
+ @Override
+ public List<Long> findRecentMessageUidsInMailbox(Mailbox<Id> mailbox)
+ throws MailboxException {
+ // TODO can be meaningfully cached?
+ return underlying.findRecentMessageUidsInMailbox(mailbox);
+ }
+
+ @Override
+ public MessageMetaData add(Mailbox<Id> mailbox, Message<Id> message)
+ throws MailboxException {
+ invalidateMetadata(mailbox);
+ return underlying.add(mailbox, message);
+ }
+
+ @Override
+ public Iterator<UpdatedFlags> updateFlags(Mailbox<Id> mailbox, FlagsUpdateCalculator calculator, MessageRange set)
+ throws MailboxException {
+ //check if there are in fact any updates
+ if (set.iterator().hasNext())
+ invalidateMetadata(mailbox);
+ return underlying.updateFlags(mailbox, calculator, set);
+ }
+
+
+ @Override
+ public MessageMetaData copy(Mailbox<Id> mailbox, Message<Id> original)
+ throws MailboxException {
+ invalidateMetadata(mailbox);
+ return underlying.copy(mailbox, original);
+ }
+
+ @Override
+ public long getLastUid(Mailbox<Id> mailbox) throws MailboxException {
+ return cache.getLastUid(mailbox, underlying);
+ }
+
+ @Override
+ public long getHighestModSeq(Mailbox<Id> mailbox) throws MailboxException {
+ return cache.getHighestModSeq(mailbox, underlying);
+ }
+
+ private void invalidateMetadata(Mailbox<Id> mailbox) {
+ cache.invalidate(mailbox);
+
+ }
@Override
public MessageMetaData move(Mailbox<Id> mailbox, Message<Id> original) throws MailboxException {
---------------------------------------------------------------------
To unsubscribe, e-mail: server-dev-unsubscribe@james.apache.org
For additional commands, e-mail: server-dev-help@james.apache.org