diff --git a/spring-eai-core/src/main/java/org/springframework/eai/message/MessageHeader.java b/spring-eai-core/src/main/java/org/springframework/eai/message/MessageHeader.java
index 1fc6595960..8852e58360 100644
--- a/spring-eai-core/src/main/java/org/springframework/eai/message/MessageHeader.java
+++ b/spring-eai-core/src/main/java/org/springframework/eai/message/MessageHeader.java
@@ -16,6 +16,7 @@
package org.springframework.eai.message;
+import java.util.Date;
import java.util.Map;
import java.util.Properties;
import java.util.concurrent.ConcurrentHashMap;
@@ -38,6 +39,8 @@ public class MessageHeader {
private String replyChannelName;
+ private Date expiration;
+
private int sequenceNumber = 1;
private int sequenceSize = 1;
@@ -76,6 +79,22 @@ public class MessageHeader {
return this.sequenceNumber;
}
+ /**
+ * Set the expiration date for this message or null
+ * to indicate 'never expire'. The default is null.
+ */
+ public void setExpiration(Date expiration) {
+ this.expiration = expiration;
+ }
+
+ /**
+ * Return the expiration date for this message or
+ * null to indicate 'never expire'.
+ */
+ public Date getExpiration() {
+ return this.expiration;
+ }
+
public void setSequenceNumber(int sequenceNumber) {
this.sequenceNumber = sequenceNumber;
}