Include impacted changes for APPC-346,APPC-348

[appc.git] / appc-dispatcher / appc-dispatcher-common / execution-queue-management-lib / src / main / java / org / onap / appc / executionqueue / impl / object / QueueMessage.java

diff --git a/appc-dispatcher/appc-dispatcher-common/execution-queue-management-lib/src/main/java/org/onap/appc/executionqueue/impl/object/QueueMessage.java b/appc-dispatcher/appc-dispatcher-common/execution-queue-management-lib/src/main/java/org/onap/appc/executionqueue/impl/object/QueueMessage.java
index bb48da7..75d1275 100644 (file)
--- a/appc-dispatcher/appc-dispatcher-common/execution-queue-management-lib/src/main/java/org/onap/appc/executionqueue/impl/object/QueueMessage.java
+++ b/appc-dispatcher/appc-dispatcher-common/execution-queue-management-lib/src/main/java/org/onap/appc/executionqueue/impl/object/QueueMessage.java
@@ -24,23 +24,22 @@
 
 package org.onap.appc.executionqueue.impl.object;
 
-import java.time.Instant;
-import java.util.Objects;
+import java.util.Date;
 
 
 public class QueueMessage<M extends Runnable> {
-    private final M message;
-    private final Instant expirationTime;
-    public QueueMessage(M message, Instant expirationTime){
+    M message;
+    Date expirationTime;
+    public QueueMessage(M message, Date expirationTime){
         this.message = message;
-        this.expirationTime = Objects.requireNonNull(expirationTime);
+        this.expirationTime = expirationTime;
     }
 
     public M getMessage() {
         return message;
     }
 
-    public boolean isExpired() {
-        return expirationTime.isBefore(Instant.now());
+    public Date getExpirationTime() {
+        return expirationTime;
     }
 }