From 7d9c65a108bbfce604c71f187169f6527628b4a8 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 27 Sep 2016 12:46:02 -0400 Subject: [PATCH] INT-4119: `PROPERTY` access for `MessageDocument` JIRA: https://jira.spring.io/browse/INT-4119 * Mark `MessageDocument` with the `@AccessType(AccessType.Type.PROPERTY)` for better performance via bean accessors * Add more getters for `MessageDocument` properties * Leave `MessageWrapper` as is since it has a complex internal logic which may be broker via accessors --- .../mongodb/store/MessageDocument.java | 23 +++++++++++++++---- 1 file changed, 18 insertions(+), 5 deletions(-) diff --git a/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MessageDocument.java b/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MessageDocument.java index 93be26aa41..3e8b635e51 100644 --- a/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MessageDocument.java +++ b/spring-integration-mongodb/src/main/java/org/springframework/integration/mongodb/store/MessageDocument.java @@ -18,6 +18,7 @@ package org.springframework.integration.mongodb.store; import java.util.UUID; +import org.springframework.data.annotation.AccessType; import org.springframework.data.annotation.Id; import org.springframework.data.mongodb.core.mapping.Document; import org.springframework.messaging.Message; @@ -30,6 +31,7 @@ import org.springframework.util.Assert; * @since 4.0 */ @Document +@AccessType(AccessType.Type.PROPERTY) public class MessageDocument { /* @@ -37,21 +39,17 @@ public class MessageDocument { * when the application context is configured with auditing. The document is not * currently Auditable. */ - @SuppressWarnings("unused") @Id private String _id; private final Message message; - @SuppressWarnings("unused") private final UUID messageId; - @SuppressWarnings("unused") private Integer priority; private Long createdTime = 0L; - @SuppressWarnings("unused") private Object groupId; private Long lastModifiedTime = 0L; @@ -60,7 +58,6 @@ public class MessageDocument { private Integer lastReleasedSequence = 0; - @SuppressWarnings("unused") private int sequence; public MessageDocument(Message message) { @@ -117,4 +114,20 @@ public class MessageDocument { this.sequence = sequence; } + public UUID getMessageId() { + return this.messageId; + } + + public Integer getPriority() { + return this.priority; + } + + public Object getGroupId() { + return this.groupId; + } + + public int getSequence() { + return this.sequence; + } + }