You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by rc...@apache.org on 2021/05/25 08:58:33 UTC
[james-project] 04/05: JAMES-3516 Add getThreadId method to
MessageResult and fix its implementations
This is an automated email from the ASF dual-hosted git repository.
rcordier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git
commit cc5f2b345448e01738aa3a878baf670095581abc
Author: quanth <hq...@linagora.com>
AuthorDate: Fri May 21 15:17:06 2021 +0700
JAMES-3516 Add getThreadId method to MessageResult and fix its implementations
---
.../main/java/org/apache/james/mailbox/model/MessageResult.java | 2 ++
.../java/org/apache/james/mailbox/store/MessageResultImpl.java | 8 +++++++-
.../apache/james/mailbox/store/StoreMessageResultIterator.java | 6 ++++++
3 files changed, 15 insertions(+), 1 deletion(-)
diff --git a/mailbox/api/src/main/java/org/apache/james/mailbox/model/MessageResult.java b/mailbox/api/src/main/java/org/apache/james/mailbox/model/MessageResult.java
index 515507b..331ddf6 100644
--- a/mailbox/api/src/main/java/org/apache/james/mailbox/model/MessageResult.java
+++ b/mailbox/api/src/main/java/org/apache/james/mailbox/model/MessageResult.java
@@ -62,6 +62,8 @@ import org.apache.james.mailbox.exception.MailboxException;
public interface MessageResult extends Comparable<MessageResult> {
MessageId getMessageId();
+ ThreadId getThreadId();
+
Date getInternalDate();
Flags getFlags();
diff --git a/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageResultImpl.java b/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageResultImpl.java
index c7671c9..f4cee70 100644
--- a/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageResultImpl.java
+++ b/mailbox/store/src/main/java/org/apache/james/mailbox/store/MessageResultImpl.java
@@ -42,6 +42,7 @@ import org.apache.james.mailbox.model.MessageMetaData;
import org.apache.james.mailbox.model.MessageResult;
import org.apache.james.mailbox.model.MimeDescriptor;
import org.apache.james.mailbox.model.MimePath;
+import org.apache.james.mailbox.model.ThreadId;
import org.apache.james.mailbox.store.mail.model.MailboxMessage;
import org.apache.james.mailbox.store.streaming.InputStreamContent;
import org.apache.james.mailbox.store.streaming.InputStreamContent.Type;
@@ -87,7 +88,12 @@ public class MessageResultImpl implements MessageResult {
public MessageId getMessageId() {
return message.getMessageId();
}
-
+
+ @Override
+ public ThreadId getThreadId() {
+ return message.getThreadId();
+ }
+
@Override
public Date getInternalDate() {
return message.getInternalDate();
diff --git a/mailbox/store/src/main/java/org/apache/james/mailbox/store/StoreMessageResultIterator.java b/mailbox/store/src/main/java/org/apache/james/mailbox/store/StoreMessageResultIterator.java
index 2fcd537..0d5ea7a 100644
--- a/mailbox/store/src/main/java/org/apache/james/mailbox/store/StoreMessageResultIterator.java
+++ b/mailbox/store/src/main/java/org/apache/james/mailbox/store/StoreMessageResultIterator.java
@@ -46,6 +46,7 @@ import org.apache.james.mailbox.model.MessageResult;
import org.apache.james.mailbox.model.MessageResultIterator;
import org.apache.james.mailbox.model.MimeDescriptor;
import org.apache.james.mailbox.model.MimePath;
+import org.apache.james.mailbox.model.ThreadId;
import org.apache.james.mailbox.store.mail.MessageMapper;
import org.apache.james.mailbox.store.mail.MessageMapper.FetchType;
import org.apache.james.mailbox.store.mail.model.MailboxMessage;
@@ -192,6 +193,11 @@ public class StoreMessageResultIterator implements MessageResultIterator {
}
@Override
+ public ThreadId getThreadId() {
+ return new ThreadId(messageMetaData.getMessageId());
+ }
+
+ @Override
public Date getInternalDate() {
return messageMetaData().getInternalDate();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org