From 696335381a128f2a02c254b2b0e78fcfa9bddbf1 Mon Sep 17 00:00:00 2001
From: guzeng <gz@flyrise.cn>
Date: Fri, 18 Jun 2021 16:41:39 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=8D=95=E5=85=83=E6=B5=8B?=
 =?UTF-8?q?=E8=AF=95=E6=96=87=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 client_test.go     |  4 +---
 send_delay_test.go | 25 +++++++++++++++++++++++++
 2 files changed, 26 insertions(+), 3 deletions(-)
 create mode 100644 send_delay_test.go

diff --git a/client_test.go b/client_test.go
index 55f3903..cc2952e 100644
--- a/client_test.go
+++ b/client_test.go
@@ -1,7 +1,6 @@
 package rabbitmqrpc
 
 import (
-	"encoding/json"
 	"testing"
 )
 
@@ -18,9 +17,8 @@ func Test_Send(t *testing.T) {
 			"order_sn": "cccc",
 		},
 	}
-	data, _ := json.Marshal(msg)
 
-	ret, err := Send(exchange, key, string(data))
+	ret, err := Send(exchange, key, msg)
 
 	t.Log(ret)
 	t.Log(err)
diff --git a/send_delay_test.go b/send_delay_test.go
new file mode 100644
index 0000000..01f6cc2
--- /dev/null
+++ b/send_delay_test.go
@@ -0,0 +1,25 @@
+package rabbitmqrpc
+
+import (
+	"testing"
+)
+
+func Test_SendDelay(t *testing.T) {
+
+	exchange := "ex_order_delay"
+	key := "order_expire"
+
+	msg := map[string]interface{}{
+		"site_id": "100002",
+		"dbname":  "testing",
+		"data": map[string]string{
+			"order_id": "111",
+			"order_sn": "cccc",
+		},
+	}
+
+	ret, err := SendDelay(exchange, key, msg, 20)
+
+	t.Log(ret)
+	t.Log(err)
+}