From f700743134067d3559f6e06132eb4a01bebf8b20 Mon Sep 17 00:00:00 2001
From: redkale <redkale@qq.com>
Date: Sat, 9 Nov 2024 19:02:21 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0MessageProducer.sendDelayMess?=
 =?UTF-8?q?age=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../java/org/redkale/mq/MessageProducer.java  | 23 +++++++++----------
 .../java/org/redkale/mq/spi/MessageAgent.java |  5 ++--
 2 files changed, 13 insertions(+), 15 deletions(-)

diff --git a/src/main/java/org/redkale/mq/MessageProducer.java b/src/main/java/org/redkale/mq/MessageProducer.java
index 8a7148eac..d5e262080 100644
--- a/src/main/java/org/redkale/mq/MessageProducer.java
+++ b/src/main/java/org/redkale/mq/MessageProducer.java
@@ -4,7 +4,6 @@
 package org.redkale.mq;
 
 import java.lang.reflect.Type;
-import java.time.Duration;
 import java.util.concurrent.CompletableFuture;
 import org.redkale.convert.Convert;
 
@@ -64,27 +63,27 @@ public interface MessageProducer {
     }
 
     public CompletableFuture<Void> sendDelayMessage(
-            String topic, Integer partition, Duration delay, Convert convert, Type type, Object value);
+            String topic, Integer partition, int delaySeconds, Convert convert, Type type, Object value);
 
     default CompletableFuture<Void> sendDelayMessage(
-            String topic, Integer partition, Duration delay, Convert convert, Object value) {
-        return sendDelayMessage(topic, partition, delay, convert, (Type) null, value);
+            String topic, Integer partition, int delaySeconds, Convert convert, Object value) {
+        return sendDelayMessage(topic, partition, delaySeconds, convert, (Type) null, value);
     }
 
-    default CompletableFuture<Void> sendDelayMessage(String topic, Integer partition, Duration delay, Object value) {
-        return sendDelayMessage(topic, partition, delay, (Convert) null, (Type) null, value);
+    default CompletableFuture<Void> sendDelayMessage(String topic, Integer partition, int delaySeconds, Object value) {
+        return sendDelayMessage(topic, partition, delaySeconds, (Convert) null, (Type) null, value);
     }
 
     default CompletableFuture<Void> sendDelayMessage(
-            String topic, Duration delay, Convert convert, Type type, Object value) {
-        return sendDelayMessage(topic, (Integer) null, delay, convert, type, value);
+            String topic, int delaySeconds, Convert convert, Type type, Object value) {
+        return sendDelayMessage(topic, (Integer) null, delaySeconds, convert, type, value);
     }
 
-    default CompletableFuture<Void> sendDelayMessage(String topic, Duration delay, Convert convert, Object value) {
-        return sendDelayMessage(topic, (Integer) null, delay, convert, (Type) null, value);
+    default CompletableFuture<Void> sendDelayMessage(String topic, int delaySeconds, Convert convert, Object value) {
+        return sendDelayMessage(topic, (Integer) null, delaySeconds, convert, (Type) null, value);
     }
 
-    default CompletableFuture<Void> sendDelayMessage(String topic, Duration delay, Object value) {
-        return sendDelayMessage(topic, (Integer) null, delay, (Convert) null, (Type) null, value);
+    default CompletableFuture<Void> sendDelayMessage(String topic, int delaySeconds, Object value) {
+        return sendDelayMessage(topic, (Integer) null, delaySeconds, (Convert) null, (Type) null, value);
     }
 }
diff --git a/src/main/java/org/redkale/mq/spi/MessageAgent.java b/src/main/java/org/redkale/mq/spi/MessageAgent.java
index a09eae165..4e514e496 100644
--- a/src/main/java/org/redkale/mq/spi/MessageAgent.java
+++ b/src/main/java/org/redkale/mq/spi/MessageAgent.java
@@ -7,7 +7,6 @@ package org.redkale.mq.spi;
 
 import java.lang.reflect.ParameterizedType;
 import java.lang.reflect.Type;
-import java.time.Duration;
 import java.util.*;
 import java.util.concurrent.*;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -640,9 +639,9 @@ public abstract class MessageAgent implements MessageManager {
 
         @Override
         public CompletableFuture<Void> sendDelayMessage(
-                String topic, Integer partition, Duration delay, Convert convert0, Type type, Object value) {
+                String topic, Integer partition, int delaySeconds, Convert convert0, Type type, Object value) {
             return producer.sendDelayMessage(
-                    topic, partition, delay, convert0 == null ? this.convert : convert0, type, value);
+                    topic, partition, delaySeconds, convert0 == null ? this.convert : convert0, type, value);
         }
     }
 }