Message timestamp is now a long (instead of java.util.Date).
This commit is contained in:
@@ -31,7 +31,7 @@ import java.util.concurrent.ConcurrentMap;
|
||||
*/
|
||||
public class DefaultMessageHeader implements MessageHeader, Serializable {
|
||||
|
||||
private final Date timestamp = new Date();
|
||||
private final long timestamp = System.currentTimeMillis();
|
||||
|
||||
private volatile Date expiration;
|
||||
|
||||
@@ -51,9 +51,9 @@ public class DefaultMessageHeader implements MessageHeader, Serializable {
|
||||
|
||||
|
||||
/**
|
||||
* Return the creation time of this message.
|
||||
* Return the creation time of this message (in milliseconds).
|
||||
*/
|
||||
public Date getTimestamp() {
|
||||
public long getTimestamp() {
|
||||
return this.timestamp;
|
||||
}
|
||||
|
||||
|
||||
@@ -30,7 +30,7 @@ import java.util.Set;
|
||||
*/
|
||||
public interface MessageHeader {
|
||||
|
||||
Date getTimestamp();
|
||||
long getTimestamp();
|
||||
|
||||
Date getExpiration();
|
||||
|
||||
|
||||
@@ -116,7 +116,7 @@ public class WireTapTests {
|
||||
Message<?> original = mainChannel.receive(0);
|
||||
Message<?> duplicate = secondaryChannel.receive(0);
|
||||
assertTrue("original timestamp should precede duplicate",
|
||||
original.getHeader().getTimestamp().before(duplicate.getHeader().getTimestamp()));
|
||||
original.getHeader().getTimestamp() < duplicate.getHeader().getTimestamp());
|
||||
}
|
||||
|
||||
public void testDuplicateMessageContainsAttribute() {
|
||||
|
||||
Reference in New Issue
Block a user