From 234fdec4be1110f6f6582ffb4b603e667fea1518 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Tue, 20 Nov 2007 15:01:09 +0000 Subject: [PATCH] Added Message expiration property to header. --- .../eai/message/MessageHeader.java | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) 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; }