You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@james.apache.org by bt...@apache.org on 2022/09/09 12:03:30 UTC

[james-project] 02/02: JAMES-3815 bodyStartOctet and size should return null value instead of default 0

This is an automated email from the ASF dual-hosted git repository.

btellier pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/james-project.git

commit 21b101732c6c289f656202987e7c1c4a847c667d
Author: Quan Tran <hq...@linagora.com>
AuthorDate: Thu Sep 8 10:57:33 2022 +0700

    JAMES-3815 bodyStartOctet and size should return null value instead of default 0
---
 .../apache/james/mailbox/cassandra/mail/CassandraMessageIdDAO.java    | 4 ++--
 .../james/mailbox/cassandra/mail/CassandraMessageIdToImapUidDAO.java  | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdDAO.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdDAO.java
index bc14228140..cb94e0ec12 100644
--- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdDAO.java
+++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdDAO.java
@@ -524,10 +524,10 @@ public class CassandraMessageIdDAO {
                 .modSeq(ModSeq.of(row.getLong(MOD_SEQ_LOWERCASE)))
                 .threadId(getThreadIdFromRow(row, messageId))
                 .build())
-            .bodyStartOctet(row.getInt(BODY_START_OCTET_LOWERCASE))
+            .bodyStartOctet(row.get(BODY_START_OCTET_LOWERCASE, Integer.class))
             .internalDate(Optional.ofNullable(row.getInstant(INTERNAL_DATE_LOWERCASE))
                 .map(Date::from))
-            .size(row.getLong(FULL_CONTENT_OCTETS_LOWERCASE))
+            .size(row.get(FULL_CONTENT_OCTETS_LOWERCASE, Long.class))
             .headerContent(Optional.ofNullable(row.getString(HEADER_CONTENT_LOWERCASE))
                 .map(blobIdFactory::from))
             .build());
diff --git a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdToImapUidDAO.java b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdToImapUidDAO.java
index 9c7888022b..26e4d2da46 100644
--- a/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdToImapUidDAO.java
+++ b/mailbox/cassandra/src/main/java/org/apache/james/mailbox/cassandra/mail/CassandraMessageIdToImapUidDAO.java
@@ -402,10 +402,10 @@ public class CassandraMessageIdToImapUidDAO {
                 .threadId(getThreadIdFromRow(row, messageId))
                 .modSeq(ModSeq.of(row.getLong(MOD_SEQ_LOWERCASE)))
                 .build())
-            .bodyStartOctet(row.getInt(BODY_START_OCTET_LOWERCASE))
+            .bodyStartOctet(row.get(BODY_START_OCTET_LOWERCASE, Integer.class))
             .internalDate(Optional.ofNullable(row.getInstant(INTERNAL_DATE_LOWERCASE))
                 .map(Date::from))
-            .size(row.getLong(FULL_CONTENT_OCTETS_LOWERCASE))
+            .size(row.get(FULL_CONTENT_OCTETS_LOWERCASE, Long.class))
             .headerContent(Optional.ofNullable(row.getString(HEADER_CONTENT_LOWERCASE))
                 .map(blobIdFactory::from))
             .build();


---------------------------------------------------------------------
To unsubscribe, e-mail: notifications-unsubscribe@james.apache.org
For additional commands, e-mail: notifications-help@james.apache.org